Show / Hide Table of Contents

    Class PingRequestObserver

    Inheritance
    System.Object
    MessageObserverBase
    RequestObserverBase<PingRequest, PingResponse>
    PingRequestObserver
    Implements
    System.IDisposable
    IRequestMessageObserver
    IP2PMessageObserver
    IMessageObserver
    System.IObserver<IObserverDto<ProtocolMessage>>
    Inherited Members
    RequestObserverBase<PingRequest, PingResponse>.PeerSettings
    RequestObserverBase<PingRequest, PingResponse>.HandleRequest(PingRequest, IChannelHandlerContext, PeerId, ICorrelationId)
    RequestObserverBase<PingRequest, PingResponse>.OnNext(IObserverDto<ProtocolMessage>)
    MessageObserverBase.Logger
    MessageObserverBase.MessageSubscription
    MessageObserverBase.StartObserving(IObservable<IObserverDto<ProtocolMessage>>)
    MessageObserverBase.OnNext(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.Lib.P2P.IO.Observers
    Assembly: Catalyst.Core.Lib.dll
    Syntax
    public sealed class PingRequestObserver : RequestObserverBase<PingRequest, PingResponse>, IDisposable, IRequestMessageObserver, IP2PMessageObserver, IMessageObserver, IObserver<IObserverDto<ProtocolMessage>>

    Constructors

    | Improve this Doc View Source

    PingRequestObserver(IPeerSettings, ILogger)

    Declaration
    public PingRequestObserver(IPeerSettings peerSettings, ILogger logger)
    Parameters
    Type Name Description
    IPeerSettings peerSettings
    ILogger logger

    Methods

    | Improve this Doc View Source

    HandleRequest(PingRequest, IChannelHandlerContext, PeerId, ICorrelationId)

    Declaration
    protected override PingResponse HandleRequest(PingRequest pingRequest, IChannelHandlerContext channelHandlerContext, PeerId senderPeerId, ICorrelationId correlationId)
    Parameters
    Type Name Description
    PingRequest pingRequest
    IChannelHandlerContext channelHandlerContext
    PeerId senderPeerId
    ICorrelationId correlationId
    Returns
    Type Description
    PingResponse
    Overrides
    Catalyst.Core.Lib.IO.Observers.RequestObserverBase<PingRequest, PingResponse>.HandleRequest(PingRequest, IChannelHandlerContext, PeerId, Catalyst.Abstractions.IO.Messaging.Correlation.ICorrelationId)

    Implements

    System.IDisposable
    IRequestMessageObserver
    IP2PMessageObserver
    IMessageObserver
    System.IObserver<T>
    • Improve this Doc
    • View Source
    Back to top Copyright © 2019 Catalyst Network