Class ObservableServiceHandler

This handler terminates DotNetty involvement and passes service messages into rx land, by this point all messages should be treated as genuine and sanitised.

Inheritance
System.Object
InboundChannelHandlerBase<ProtocolMessage>
ObservableServiceHandler
Implements
IChannelHandler
System.IDisposable
Inherited Members
Namespace: Catalyst.Core.Lib.IO.Handlers
Assembly: Catalyst.Core.Lib.dll
Syntax
public sealed class ObservableServiceHandler : InboundChannelHandlerBase<ProtocolMessage>, IObservableServiceHandler, IChannelHandler, IObservableMessageStreamer<ProtocolMessage>, IDisposable

Constructors

| Improve this Doc View Source

ObservableServiceHandler(IScheduler)

Declaration
public ObservableServiceHandler(IScheduler scheduler = null)
Parameters
Type Name Description
IScheduler scheduler

Properties

| Improve this Doc View Source

IsSharable

Declaration
public override bool IsSharable { get; }
Property Value
Type Description
System.Boolean
| 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

ChannelRead0(IChannelHandlerContext, ProtocolMessage)

Reads the channel once accepted and pushed into a stream.

Declaration
protected override void ChannelRead0(IChannelHandlerContext ctx, ProtocolMessage message)
Parameters
Type Name Description
IChannelHandlerContext ctx
ProtocolMessage message
Overrides
Catalyst.Core.Lib.IO.Handlers.InboundChannelHandlerBase<ProtocolMessage>.ChannelRead0(IChannelHandlerContext, ProtocolMessage)
| Improve this Doc View Source

Dispose()

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

ExceptionCaught(IChannelHandlerContext, Exception)

Declaration
public override void ExceptionCaught(IChannelHandlerContext context, Exception e)
Parameters
Type Name Description
IChannelHandlerContext context
System.Exception e

Implements

IChannelHandler
System.IDisposable