Class RequestObserverBase<TProtoReq, TProtoRes>

Inheritance
System.Object
MessageObserverBase
RequestObserverBase<TProtoReq, TProtoRes>
GetNeighbourRequestObserver
PingRequestObserver
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 RequestObserverBase<TProtoReq, TProtoRes> : MessageObserverBase, IDisposable, IRequestMessageObserver, IMessageObserver, IObserver<IObserverDto<ProtocolMessage>> where TProtoReq : IMessage<TProtoReq> where TProtoRes : IMessage<TProtoRes>
Type Parameters
Name Description
TProtoReq
TProtoRes

Constructors

| Improve this Doc View Source

RequestObserverBase(ILogger, IPeerSettings)

Declaration
protected RequestObserverBase(ILogger logger, IPeerSettings peerSettings)
Parameters
Type Name Description
ILogger logger
IPeerSettings peerSettings

Properties

| Improve this Doc View Source

PeerSettings

Declaration
public IPeerSettings PeerSettings { get; }
Property Value
Type Description
IPeerSettings

Methods

| Improve this Doc View Source

HandleRequest(TProtoReq, IChannelHandlerContext, PeerId, ICorrelationId)

Declaration
protected abstract TProtoRes HandleRequest(TProtoReq messageDto, IChannelHandlerContext channelHandlerContext, PeerId senderPeerId, ICorrelationId correlationId)
Parameters
Type Name Description
TProtoReq messageDto
IChannelHandlerContext channelHandlerContext
PeerId senderPeerId
ICorrelationId correlationId
Returns
Type Description
TProtoRes
| 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>