Class RpcResponseObserver<TProto>

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

Constructors

| Improve this Doc View Source

RpcResponseObserver(ILogger, Boolean)

Declaration
protected RpcResponseObserver(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 override void HandleResponse(TProto messageDto, IChannelHandlerContext channelHandlerContext, PeerId senderPeerId, ICorrelationId correlationId)
Parameters
Type Name Description
TProto messageDto
IChannelHandlerContext channelHandlerContext
PeerId senderPeerId
ICorrelationId correlationId
Overrides
Catalyst.Core.Lib.IO.Observers.ResponseObserverBase<TProto>.HandleResponse(TProto, IChannelHandlerContext, PeerId, Catalyst.Abstractions.IO.Messaging.Correlation.ICorrelationId)
| Improve this Doc View Source

HandleResponseObserver(IMessage, IChannelHandlerContext, PeerId, ICorrelationId)

Declaration
public void HandleResponseObserver(IMessage message, IChannelHandlerContext channelHandlerContext, PeerId senderPeerId, ICorrelationId correlationId)
Parameters
Type Name Description
IMessage message
IChannelHandlerContext channelHandlerContext
PeerId senderPeerId
ICorrelationId correlationId

Implements

System.IDisposable
System.IObserver<T>