Class PeerCountRequestObserver

Peer count request handler

Inheritance
System.Object
MessageObserverBase
RequestObserverBase<GetPeerCountRequest, GetPeerCountResponse>
PeerCountRequestObserver
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 PeerCountRequestObserver : RequestObserverBase<GetPeerCountRequest, GetPeerCountResponse>, IDisposable, IRequestMessageObserver, IRpcRequestObserver, IMessageObserver, IObserver<IObserverDto<ProtocolMessage>>

Constructors

| Improve this Doc View Source

PeerCountRequestObserver(IPeerSettings, IPeerRepository, ILogger)

Initializes a new instance of the PeerCountRequestObserver class.

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

The peer discovery.
ILogger logger

The logger.

Methods

| Improve this Doc View Source

HandleRequest(GetPeerCountRequest, IChannelHandlerContext, PeerId, ICorrelationId)

Declaration
protected override GetPeerCountResponse HandleRequest(GetPeerCountRequest getPeerCountRequest, IChannelHandlerContext channelHandlerContext, PeerId senderPeerId, ICorrelationId correlationId)
Parameters
Type Name Description
GetPeerCountRequest getPeerCountRequest
IChannelHandlerContext channelHandlerContext
PeerId senderPeerId
ICorrelationId correlationId
Returns
Type Description
GetPeerCountResponse

Implements

System.IDisposable
System.IObserver<T>

See Also