Class ResponseObserverBase<TProto>

Inheritance
System.Object
MessageObserverBase
ResponseObserverBase<TProto>
GetNeighbourResponseObserver
PingResponseObserver
RpcResponseObserver<TProto>
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.IO.Observers
Assembly: Catalyst.Core.Lib.dll
Syntax
public abstract class ResponseObserverBase<TProto> : MessageObserverBase, IDisposable, IResponseMessageObserver, IMessageObserver, IObserver<IObserverDto<ProtocolMessage>> where TProto : IMessage<TProto>
Type Parameters
Name Description
TProto

Constructors

| Improve this Doc View Source

ResponseObserverBase(ILogger, Boolean)

Declaration
protected ResponseObserverBase(ILogger logger, bool assertMessageNameCheck = true)
Parameters
Type Name Description
ILogger logger
System.Boolean assertMessageNameCheck

Methods

| Improve this Doc View Source

HandleResponse(TProto, IChannelHandlerContext, PeerId, ICorrelationId)

Declaration
protected abstract void HandleResponse(TProto messageDto, IChannelHandlerContext channelHandlerContext, PeerId senderPeerId, ICorrelationId correlationId)
Parameters
Type Name Description
TProto messageDto
IChannelHandlerContext channelHandlerContext
PeerId senderPeerId
ICorrelationId correlationId
| Improve this Doc View Source

OnNext(IObserverDto<ProtocolMessage>)

Declaration
public override void OnNext(IObserverDto<ProtocolMessage> messageDto)
Parameters
Type Name Description
IObserverDto<ProtocolMessage> messageDto
Overrides

Implements

System.IDisposable
System.IObserver<T>