Class RpcMessagePackIpc

Namespace

DotBoxD.Pushdown.Services

Assembly

DotBoxD.Pushdown.Services.dll

public static class RpcMessagePackIpc

Inheritance

object

RpcMessagePackIpc

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Methods

ConnectAsync(ITransport, RpcPeerOptions?, CancellationToken)

public static Task<RpcPeerSession> ConnectAsync(ITransport transport, RpcPeerOptions? options = null, CancellationToken cancellationToken = default)

Parameters

transport ITransport

options RpcPeerOptions

cancellationToken CancellationToken

Returns

Task<RpcPeerSession>

ConnectAsync(ITransport, Action<RpcPeer>, RpcPeerOptions?, CancellationToken)

public static Task<RpcPeerSession> ConnectAsync(ITransport transport, Action<RpcPeer> configurePeer, RpcPeerOptions? options = null, CancellationToken cancellationToken = default)

Parameters

transport ITransport

configurePeer Action<RpcPeer>

options RpcPeerOptions

cancellationToken CancellationToken

Returns

Task<RpcPeerSession>

ConnectNamedPipeAsync(string, NamedPipeTransportOptions, RpcPeerOptions?, CancellationToken)

public static Task<RpcPeerSession> ConnectNamedPipeAsync(string pipeName, NamedPipeTransportOptions namedPipeOptions, RpcPeerOptions? options = null, CancellationToken cancellationToken = default)

Parameters

pipeName string

namedPipeOptions NamedPipeTransportOptions

options RpcPeerOptions

cancellationToken CancellationToken

Returns

Task<RpcPeerSession>

ConnectNamedPipeAsync(string, RpcPeerOptions?, CancellationToken)

public static Task<RpcPeerSession> ConnectNamedPipeAsync(string pipeName, RpcPeerOptions? options = null, CancellationToken cancellationToken = default)

Parameters

pipeName string

options RpcPeerOptions

cancellationToken CancellationToken

Returns

Task<RpcPeerSession>

ConnectNamedPipeAsync(string, Action<RpcPeer>?, NamedPipeTransportOptions?, RpcPeerOptions?, CancellationToken)

Connects to a named-pipe server and, when configurePeer is supplied, registers bidirectional services on the peer before it starts — the only point at which a client may provide a reverse callback (e.g. a remote RunLocal event sink). A null callback connects without registering any client-side service. The pipe name is validated as in the other overloads.

public static Task<RpcPeerSession> ConnectNamedPipeAsync(string pipeName, Action<RpcPeer>? configurePeer, NamedPipeTransportOptions? namedPipeOptions = null, RpcPeerOptions? options = null, CancellationToken cancellationToken = default)

Parameters

pipeName string

configurePeer Action<RpcPeer>

namedPipeOptions NamedPipeTransportOptions

options RpcPeerOptions

cancellationToken CancellationToken

Returns

Task<RpcPeerSession>

ConnectNamedPipeAsync(string, string, NamedPipeTransportOptions, RpcPeerOptions?, CancellationToken)

public static Task<RpcPeerSession> ConnectNamedPipeAsync(string serverName, string pipeName, NamedPipeTransportOptions namedPipeOptions, RpcPeerOptions? options = null, CancellationToken cancellationToken = default)

Parameters

serverName string

pipeName string

namedPipeOptions NamedPipeTransportOptions

options RpcPeerOptions

cancellationToken CancellationToken

Returns

Task<RpcPeerSession>

ConnectNamedPipeAsync(string, string, RpcPeerOptions?, CancellationToken)

public static Task<RpcPeerSession> ConnectNamedPipeAsync(string serverName, string pipeName, RpcPeerOptions? options = null, CancellationToken cancellationToken = default)

Parameters

serverName string

pipeName string

options RpcPeerOptions

cancellationToken CancellationToken

Returns

Task<RpcPeerSession>

Listen(IServerTransport, Action<RpcPeer>, RpcPeerOptions?)

public static RpcHost Listen(IServerTransport transport, Action<RpcPeer> configurePeer, RpcPeerOptions? options = null)

Parameters

transport IServerTransport

configurePeer Action<RpcPeer>

options RpcPeerOptions

Returns

RpcHost

ListenNamedPipe(string, Action<RpcPeer>, NamedPipeTransportOptions, RpcPeerOptions?)

public static RpcHost ListenNamedPipe(string pipeName, Action<RpcPeer> configurePeer, NamedPipeTransportOptions namedPipeOptions, RpcPeerOptions? options = null)

Parameters

pipeName string

configurePeer Action<RpcPeer>

namedPipeOptions NamedPipeTransportOptions

options RpcPeerOptions

Returns

RpcHost

ListenNamedPipe(string, Action<RpcPeer>, RpcPeerOptions?)

public static RpcHost ListenNamedPipe(string pipeName, Action<RpcPeer> configurePeer, RpcPeerOptions? options = null)

Parameters

pipeName string

configurePeer Action<RpcPeer>

options RpcPeerOptions

Returns

RpcHost