Interface IRpcResponseObserver

Inherited Members

IMessageObserver.StartObserving(IObservable<IObserverDto<ProtocolMessage>>)

System.IObserver<Catalyst.Abstractions.IO.Messaging.Dto.IObserverDto<ProtocolMessage>>.OnCompleted()

System.IObserver<Catalyst.Abstractions.IO.Messaging.Dto.IObserverDto<ProtocolMessage>>.OnError(System.Exception)

System.IObserver<Catalyst.Abstractions.IO.Messaging.Dto.IObserverDto<ProtocolMessage>>.OnNext(Catalyst.Abstractions.IO.Messaging.Dto.IObserverDto<ProtocolMessage>)

Namespace: Catalyst.Abstractions.IO.Observers

Assembly: Catalyst.Abstractions.dll

Syntax

public interface IRpcResponseObserver : IResponseMessageObserver, IMessageObserver, IObserver<IObserverDto<ProtocolMessage>>

Methods

| Improve this Doc View Source

HandleResponseObserver(IMessage, IChannelHandlerContext, PeerId, ICorrelationId)

Declaration

void HandleResponseObserver(IMessage messageDto, IChannelHandlerContext channelHandlerContext, PeerId senderPeerIdentifier, ICorrelationId correlationId)

Parameters

Type	Name	Description
IMessage	messageDto
IChannelHandlerContext	channelHandlerContext
PeerId	senderPeerIdentifier
ICorrelationId	correlationId