Class RpcServer

Inheritance
System.Object
SocketBase
TcpServer
RpcServer
Implements
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.Modules.Rpc.Server
Assembly: Catalyst.Core.Modules.Rpc.Server.dll
Syntax
public sealed class RpcServer : TcpServer, ITcpServer, ISocketServer, IRpcServer, IObservableMessageStreamer<ProtocolMessage>, ISocket, IDisposable

Constructors

| Improve this Doc View Source

RpcServer(IRpcServerSettings, ILogger, ITcpServerChannelFactory, ICertificateStore, IEnumerable<IRpcRequestObserver>, ITcpServerEventLoopGroupFactory)

Declaration
public RpcServer(IRpcServerSettings settings, ILogger logger, ITcpServerChannelFactory channelFactory, ICertificateStore certificateStore, IEnumerable<IRpcRequestObserver> requestHandlers, ITcpServerEventLoopGroupFactory eventEventLoopGroupFactory)
Parameters
Type Name Description
IRpcServerSettings settings
ILogger logger
ITcpServerChannelFactory channelFactory
ICertificateStore certificateStore
System.Collections.Generic.IEnumerable<IRpcRequestObserver> requestHandlers
ITcpServerEventLoopGroupFactory eventEventLoopGroupFactory

Properties

| Improve this Doc View Source

MessageStream

Declaration
public IObservable<IObserverDto<ProtocolMessage>> MessageStream { get; }
Property Value
Type Description
System.IObservable<IObserverDto<ProtocolMessage>>
| Improve this Doc View Source

Settings

Declaration
public IRpcServerSettings Settings { get; }
Property Value
Type Description
IRpcServerSettings

Methods

| Improve this Doc View Source

Dispose(Boolean)

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

StartAsync()

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

Implements

System.IDisposable