Class GetMempoolRequestObserver

Inheritance
System.Object
MessageObserverBase
RequestObserverBase<GetMempoolRequest, GetMempoolResponse>
GetMempoolRequestObserver
Implements
System.IDisposable
System.IObserver<IObserverDto<ProtocolMessage>>
Inherited Members
System.Object.Equals(System.Object)
System.Object.Equals(System.Object, System.Object)
System.Object.GetHashCode()
System.Object.GetType()
System.Object.MemberwiseClone()
System.Object.ReferenceEquals(System.Object, System.Object)
System.Object.ToString()
Namespace: Catalyst.Core.Modules.Rpc.Server.IO.Observers
Assembly: Catalyst.Core.Modules.Rpc.Server.dll
Syntax
public sealed class GetMempoolRequestObserver : RequestObserverBase<GetMempoolRequest, GetMempoolResponse>, IDisposable, IRequestMessageObserver, IRpcRequestObserver, IMessageObserver, IObserver<IObserverDto<ProtocolMessage>>

Constructors

| Improve this Doc View Source

GetMempoolRequestObserver(IPeerSettings, IMempool<MempoolDocument>, ILogger)

Declaration
public GetMempoolRequestObserver(IPeerSettings peerSettings, IMempool<MempoolDocument> mempool, ILogger logger)
Parameters
Type Name Description
IPeerSettings peerSettings
IMempool<MempoolDocument> mempool
ILogger logger

Methods

| Improve this Doc View Source

HandleRequest(GetMempoolRequest, IChannelHandlerContext, PeerId, ICorrelationId)

Declaration
protected override GetMempoolResponse HandleRequest(GetMempoolRequest getMempoolRequest, IChannelHandlerContext channelHandlerContext, PeerId senderPeerId, ICorrelationId correlationId)
Parameters
Type Name Description
GetMempoolRequest getMempoolRequest
IChannelHandlerContext channelHandlerContext
PeerId senderPeerId
ICorrelationId correlationId
Returns
Type Description
GetMempoolResponse

Implements

System.IDisposable
System.IObserver<T>