Class RemovePeerRequestObserver

Remove Peer handler

Inheritance
System.Object
MessageObserverBase
RequestObserverBase<RemovePeerRequest, RemovePeerResponse>
RemovePeerRequestObserver
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 RemovePeerRequestObserver : RequestObserverBase<RemovePeerRequest, RemovePeerResponse>, IDisposable, IRequestMessageObserver, IRpcRequestObserver, IMessageObserver, IObserver<IObserverDto<ProtocolMessage>>

Constructors

| Improve this Doc View Source

RemovePeerRequestObserver(IPeerSettings, IPeerRepository, ILogger)

Initializes a new instance of the RemovePeerRequestObserver class.

Declaration
public RemovePeerRequestObserver(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(RemovePeerRequest, IChannelHandlerContext, PeerId, ICorrelationId)

Declaration
protected override RemovePeerResponse HandleRequest(RemovePeerRequest removePeerRequest, IChannelHandlerContext channelHandlerContext, PeerId senderPeerId, ICorrelationId correlationId)
Parameters
Type Name Description
RemovePeerRequest removePeerRequest
IChannelHandlerContext channelHandlerContext
PeerId senderPeerId
ICorrelationId correlationId
Returns
Type Description
RemovePeerResponse

Implements

System.IDisposable
System.IObserver<T>

See Also