Show / Hide Table of Contents

    Class GetPeerInfoResponseObserver

    Handles the Peer reputation response

    Inheritance
    System.Object
    MessageObserverBase
    ResponseObserverBase<GetPeerInfoResponse>
    RpcResponseObserver<GetPeerInfoResponse>
    GetPeerInfoResponseObserver
    Implements
    IMessageObserver
    System.IDisposable
    IResponseMessageObserver
    IRpcResponseObserver
    Inherited Members
    RpcResponseObserver<GetPeerInfoResponse>.HandleResponse(GetPeerInfoResponse, IChannelHandlerContext, PeerId, ICorrelationId)
    RpcResponseObserver<GetPeerInfoResponse>.HandleResponseObserver(IMessage, IChannelHandlerContext, PeerId, ICorrelationId)
    ResponseObserverBase<GetPeerInfoResponse>.OnNext(IObserverDto<ProtocolMessage>)
    MessageObserverBase.Logger
    MessageObserverBase.MessageSubscription
    MessageObserverBase.StartObserving(IObservable<IObserverDto<ProtocolMessage>>)
    MessageObserverBase.OnCompleted()
    MessageObserverBase.OnError(Exception)
    MessageObserverBase.Dispose(Boolean)
    MessageObserverBase.Dispose()
    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.Modules.Rpc.Client.IO.Observers
    Assembly: Catalyst.Core.Modules.Rpc.Client.dll
    Syntax
    public sealed class GetPeerInfoResponseObserver : RpcResponseObserver<GetPeerInfoResponse>, IMessageObserver, IDisposable, IResponseMessageObserver, IRpcResponseObserver

    Constructors

    | Improve this Doc View Source

    GetPeerInfoResponseObserver(ILogger)

    Initializes a new instance of the PeerReputationResponseObserver class.

    Declaration
    public GetPeerInfoResponseObserver(ILogger logger)
    Parameters
    Type Name Description
    ILogger logger

    The logger.

    Methods

    | Improve this Doc View Source

    HandleResponse(GetPeerInfoResponse, IChannelHandlerContext, PeerId, ICorrelationId)

    Handle the response for GetPeerInfo

    Declaration
    protected override void HandleResponse(GetPeerInfoResponse getPeerInfoResponse, IChannelHandlerContext channelHandlerContext, PeerId senderPeerIdentifier, ICorrelationId correlationId)
    Parameters
    Type Name Description
    GetPeerInfoResponse getPeerInfoResponse

    The response

    IChannelHandlerContext channelHandlerContext

    The channel handler context

    PeerId senderPeerIdentifier

    The sender peer identifier

    ICorrelationId correlationId

    The correlationId

    Implements

    IMessageObserver
    System.IDisposable
    IResponseMessageObserver
    IRpcResponseObserver
    • Improve this Doc
    • View Source
    Back to top Copyright © 2019 Catalyst Network