Class PingResponseObserver

Inheritance
System.Object
MessageObserverBase
ResponseObserverBase<PingResponse>
PingResponseObserver
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 PingResponseObserver : ResponseObserverBase<PingResponse>, IDisposable, IResponseMessageObserver, IP2PMessageObserver, IMessageObserver, IObserver<IObserverDto<ProtocolMessage>>, IPeerClientObservable

Constructors

| Improve this Doc View Source

PingResponseObserver(ILogger, IPeerChallenger)

Declaration
public PingResponseObserver(ILogger logger, IPeerChallenger peerChallenger)
Parameters
Type Name Description
ILogger logger
IPeerChallenger peerChallenger

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(PingResponse, IChannelHandlerContext, PeerId, ICorrelationId)

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

Implements

System.IDisposable
System.IObserver<T>