Class GetNeighbourResponseObserver

Inheritance
System.Object
MessageObserverBase
ResponseObserverBase<PeerNeighborsResponse>
GetNeighbourResponseObserver
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.Lib.P2P.IO.Observers
Assembly: Catalyst.Core.Lib.dll
Syntax
public sealed class GetNeighbourResponseObserver : ResponseObserverBase<PeerNeighborsResponse>, IDisposable, IResponseMessageObserver, IP2PMessageObserver, IMessageObserver, IObserver<IObserverDto<ProtocolMessage>>, IPeerClientObservable

Constructors

| Improve this Doc View Source

GetNeighbourResponseObserver(ILogger)

Declaration
public GetNeighbourResponseObserver(ILogger logger)
Parameters
Type Name Description
ILogger logger

Properties

| Improve this Doc View Source

MessageStream

Declaration
public IObservable<IPeerClientMessageDto> MessageStream { get; }
Property Value
Type Description
System.IObservable<IPeerClientMessageDto>
| Improve this Doc View Source

ResponseMessageSubject

Declaration
public ReplaySubject<IPeerClientMessageDto> ResponseMessageSubject { get; }
Property Value
Type Description
ReplaySubject<IPeerClientMessageDto>

Methods

| Improve this Doc View Source

HandleResponse(PeerNeighborsResponse, IChannelHandlerContext, PeerId, ICorrelationId)

Processes a GetNeighbourResponse item from stream.

Declaration
protected override void HandleResponse(PeerNeighborsResponse messageDto, IChannelHandlerContext channelHandlerContext, PeerId senderPeerId, ICorrelationId correlationId)
Parameters
Type Name Description
PeerNeighborsResponse messageDto
IChannelHandlerContext channelHandlerContext
PeerId senderPeerId
ICorrelationId correlationId
Overrides
Catalyst.Core.Lib.IO.Observers.ResponseObserverBase<PeerNeighborsResponse>.HandleResponse(PeerNeighborsResponse, IChannelHandlerContext, PeerId, Catalyst.Abstractions.IO.Messaging.Correlation.ICorrelationId)

Implements

System.IDisposable
System.IObserver<T>