Class ObservableChannel

Inheritance
System.Object
ObservableChannel
Implements
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.Transport.Channels
Assembly: Catalyst.Core.Lib.dll
Syntax
public sealed class ObservableChannel : IObservableChannel

Constructors

| Improve this Doc View Source

ObservableChannel(IObservable<IObserverDto<ProtocolMessage>>, IChannel)

Declaration
public ObservableChannel(IObservable<IObserverDto<ProtocolMessage>> messageStream, IChannel channel)
Parameters
Type Name Description
System.IObservable<IObserverDto<ProtocolMessage>> messageStream
IChannel channel

Properties

| Improve this Doc View Source

Channel

Declaration
public IChannel Channel { get; }
Property Value
Type Description
IChannel
| Improve this Doc View Source

MessageStream

Declaration
public IObservable<IObserverDto<ProtocolMessage>> MessageStream { get; }
Property Value
Type Description
System.IObservable<IObserverDto<ProtocolMessage>>

Methods

| Improve this Doc View Source

StartAsync()

Declaration
public Task StartAsync()
Returns
Type Description
System.Threading.Tasks.Task

Implements