Class MessageObserverBase

Inheritance
System.Object
MessageObserverBase
BroadcastObserverBase<TProto>
RequestObserverBase<TProtoReq, TProtoRes>
ResponseObserverBase<TProto>
Implements
System.IObserver<IObserverDto<ProtocolMessage>>
System.IDisposable
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 MessageObserverBase : IMessageObserver, IObserver<IObserverDto<ProtocolMessage>>, IDisposable

Constructors

| Improve this Doc View Source

MessageObserverBase(ILogger, String)

Declaration
protected MessageObserverBase(ILogger logger, string filterMessageType)
Parameters
Type Name Description
ILogger logger
System.String filterMessageType

Fields

| Improve this Doc View Source

Logger

Declaration
protected readonly ILogger Logger
Field Value
Type Description
ILogger
| Improve this Doc View Source

MessageSubscription

Declaration
protected IDisposable MessageSubscription
Field Value
Type Description
System.IDisposable

Methods

| Improve this Doc View Source

Dispose()

Declaration
public void Dispose()
| Improve this Doc View Source

Dispose(Boolean)

Declaration
protected virtual void Dispose(bool disposing)
Parameters
Type Name Description
System.Boolean disposing
| Improve this Doc View Source

OnCompleted()

Declaration
public virtual void OnCompleted()
| Improve this Doc View Source

OnError(Exception)

Declaration
public virtual void OnError(Exception exception)
Parameters
Type Name Description
System.Exception exception
| Improve this Doc View Source

OnNext(IObserverDto<ProtocolMessage>)

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

StartObserving(IObservable<IObserverDto<ProtocolMessage>>)

Declaration
public void StartObserving(IObservable<IObserverDto<ProtocolMessage>> messageStream)
Parameters
Type Name Description
System.IObservable<IObserverDto<ProtocolMessage>> messageStream

Implements

System.IObserver<T>
System.IDisposable