Class PeerListRequestObserver

Handles the PeerListRequest message

Inheritance
System.Object
MessageObserverBase
RequestObserverBase<GetPeerListRequest, GetPeerListResponse>
PeerListRequestObserver
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 PeerListRequestObserver : RequestObserverBase<GetPeerListRequest, GetPeerListResponse>, IDisposable, IRequestMessageObserver, IRpcRequestObserver, IMessageObserver, IObserver<IObserverDto<ProtocolMessage>>

Constructors

| Improve this Doc View Source

PeerListRequestObserver(IPeerSettings, ILogger, IPeerRepository)

Initializes a new instance of the PeerListRequestObserver class.

Declaration
public PeerListRequestObserver(IPeerSettings peerSettings, ILogger logger, IPeerRepository peerRepository)
Parameters
Type Name Description
IPeerSettings peerSettings
ILogger logger

The logger.
IPeerRepository peerRepository

Methods

| Improve this Doc View Source

HandleRequest(GetPeerListRequest, IChannelHandlerContext, PeerId, ICorrelationId)

Declaration
protected override GetPeerListResponse HandleRequest(GetPeerListRequest getPeerListRequest, IChannelHandlerContext channelHandlerContext, PeerId senderPeerId, ICorrelationId correlationId)
Parameters
Type Name Description
GetPeerListRequest getPeerListRequest
IChannelHandlerContext channelHandlerContext
PeerId senderPeerId
ICorrelationId correlationId
Returns
Type Description
GetPeerListResponse

Implements

System.IDisposable
System.IObserver<T>

See Also