Show / Hide Table of Contents

    Class BroadcastObserverBase<TProto>

    Inheritance
    System.Object
    MessageObserverBase
    BroadcastObserverBase<TProto>
    TransactionBroadcastObserver
    Implements
    System.IDisposable
    IBroadcastObserver
    IMessageObserver
    System.IObserver<IObserverDto<ProtocolMessage>>
    Inherited Members
    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.Lib.IO.Observers
    Assembly: Catalyst.Core.Lib.dll
    Syntax
    public abstract class BroadcastObserverBase<TProto> : MessageObserverBase, IDisposable, IBroadcastObserver, IMessageObserver, IObserver<IObserverDto<ProtocolMessage>> where TProto : IMessage
    Type Parameters
    Name Description
    TProto

    Constructors

    | Improve this Doc View Source

    BroadcastObserverBase(ILogger)

    Declaration
    protected BroadcastObserverBase(ILogger logger)
    Parameters
    Type Name Description
    ILogger logger

    Methods

    | Improve this Doc View Source

    HandleBroadcast(IObserverDto<ProtocolMessage>)

    Declaration
    public abstract void HandleBroadcast(IObserverDto<ProtocolMessage> messageDto)
    Parameters
    Type Name Description
    IObserverDto<ProtocolMessage> messageDto
    | Improve this Doc View Source

    OnNext(IObserverDto<ProtocolMessage>)

    Declaration
    public override void OnNext(IObserverDto<ProtocolMessage> messageDto)
    Parameters
    Type Name Description
    IObserverDto<ProtocolMessage> messageDto
    Overrides
    MessageObserverBase.OnNext(IObserverDto<ProtocolMessage>)

    Implements

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