Show / Hide Table of Contents

    Class RpcClient

    This class provides a command line interface (CLI) application to connect to Catalyst Node. Through the CLI the node operator will be able to connect to any number of running nodes and run commands.

    Inheritance
    System.Object
    SocketBase
    ClientBase
    TcpClient
    RpcClient
    Implements
    ISocket
    ISocketClient
    ITcpClient
    IRpcClient
    Inherited Members
    ClientBase.SendMessage<T>(IMessageDto<T>)
    SocketBase.ChannelFactory
    SocketBase.EventLoopGroupFactory
    SocketBase.Channel
    SocketBase.Dispose()
    SocketBase.Dispose(Boolean)
    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.Client
    Assembly: Catalyst.Core.Modules.Rpc.Client.dll
    Syntax
    public sealed class RpcClient : TcpClient, ISocket, ISocketClient, ITcpClient, IRpcClient

    Constructors

    | Improve this Doc View Source

    RpcClient(ITcpClientChannelFactory, X509Certificate2, IRpcClientConfig, IEnumerable<IRpcResponseObserver>, ITcpClientEventLoopGroupFactory)

    Initialize a new instance of RPClient

    Declaration
    public RpcClient(ITcpClientChannelFactory channelFactory, X509Certificate2 certificate, IRpcClientConfig clientConfig, IEnumerable<IRpcResponseObserver> handlers, ITcpClientEventLoopGroupFactory clientEventLoopGroupFactory)
    Parameters
    Type Name Description
    ITcpClientChannelFactory channelFactory
    System.Security.Cryptography.X509Certificates.X509Certificate2 certificate
    IRpcClientConfig clientConfig

    rpc node config

    System.Collections.Generic.IEnumerable<IRpcResponseObserver> handlers
    ITcpClientEventLoopGroupFactory clientEventLoopGroupFactory

    Methods

    | Improve this Doc View Source

    StartAsync()

    Declaration
    public override Task StartAsync()
    Returns
    Type Description
    System.Threading.Tasks.Task
    Overrides
    SocketBase.StartAsync()
    | Improve this Doc View Source

    SubscribeToResponse<T>(Action<T>)

    Declaration
    public IDisposable SubscribeToResponse<T>(Action<T> onNext)
    
        where T : IMessage<T>
    Parameters
    Type Name Description
    System.Action<T> onNext
    Returns
    Type Description
    System.IDisposable
    Type Parameters
    Name Description
    T

    Implements

    ISocket
    ISocketClient
    ITcpClient
    IRpcClient
    • Improve this Doc
    • View Source
    Back to top Copyright © 2019 Catalyst Network