Class GetNeighbourRequestObserver
Inheritance
System.Object
GetNeighbourRequestObserver
Implements
System.IDisposable
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.Lib.P2P.IO.Observers
Assembly: Catalyst.Core.Lib.dll
Syntax
public sealed class GetNeighbourRequestObserver : RequestObserverBase<PeerNeighborsRequest, PeerNeighborsResponse>, IDisposable, IRequestMessageObserver, IP2PMessageObserver, IMessageObserver, IObserver<IObserverDto<ProtocolMessage>>Constructors
| Improve this Doc View SourceGetNeighbourRequestObserver(IPeerSettings, IPeerRepository, ILogger)
Declaration
public GetNeighbourRequestObserver(IPeerSettings peerSettings, IPeerRepository repository, ILogger logger)Parameters
| Type | Name | Description |
|---|---|---|
| IPeerSettings | peerSettings | |
| IPeerRepository | repository | |
| ILogger | logger |
Methods
| Improve this Doc View SourceHandleRequest(PeerNeighborsRequest, IChannelHandlerContext, PeerId, ICorrelationId)
Processes a GetNeighbourResponse item from stream.
Declaration
protected override PeerNeighborsResponse HandleRequest(PeerNeighborsRequest peerNeighborsRequest, IChannelHandlerContext channelHandlerContext, PeerId senderPeerId, ICorrelationId correlationId)Parameters
| Type | Name | Description |
|---|---|---|
| PeerNeighborsRequest | peerNeighborsRequest | |
| IChannelHandlerContext | channelHandlerContext | |
| PeerId | senderPeerId | |
| ICorrelationId | correlationId |
Returns
| Type | Description |
|---|---|
| PeerNeighborsResponse |
Overrides
Catalyst.Core.Lib.IO.Observers.RequestObserverBase<PeerNeighborsRequest, PeerNeighborsResponse>.HandleRequest(PeerNeighborsRequest, IChannelHandlerContext, PeerId, Catalyst.Abstractions.IO.Messaging.Correlation.ICorrelationId)
Implements
System.IDisposable
System.IObserver<T>