Class DefaultCallInvoker

Invokes client RPCs using Calls.

Inheritance

System.Object

CallInvoker

DefaultCallInvoker

Inherited Members

System.Object.ToString()

System.Object.Equals(System.Object)

System.Object.Equals(System.Object, System.Object)

System.Object.ReferenceEquals(System.Object, System.Object)

System.Object.GetHashCode()

System.Object.GetType()

System.Object.MemberwiseClone()

Namespace: Grpc.Core

Assembly: Grpc.Core.dll

Syntax

public class DefaultCallInvoker : CallInvoker

Constructors

DefaultCallInvoker(Channel)

Initializes a new instance of the DefaultCallInvoker class.

Declaration

public DefaultCallInvoker(Channel channel)

Parameters

Type	Name	Description
Channel	channel	Channel to use.

Methods

AsyncClientStreamingCall<TRequest, TResponse>(Method<TRequest, TResponse>, String, CallOptions)

Invokes a client streaming call asynchronously. In client streaming scenario, client sends a stream of requests and server responds with a single response.

Declaration

public override AsyncClientStreamingCall<TRequest, TResponse> AsyncClientStreamingCall<TRequest, TResponse>(Method<TRequest, TResponse> method, string host, CallOptions options)
    where TRequest : class where TResponse : class

Parameters

Type	Name	Description
Method<TRequest, TResponse>	method
System.String	host
CallOptions	options

Returns

Type	Description
AsyncClientStreamingCall<TRequest, TResponse>

Type Parameters

Name	Description
TRequest
TResponse

Overrides

Grpc.Core.CallInvoker.AsyncClientStreamingCall<TRequest, TResponse>(Grpc.Core.Method<TRequest, TResponse>, System.String, Grpc.Core.CallOptions)

AsyncDuplexStreamingCall<TRequest, TResponse>(Method<TRequest, TResponse>, String, CallOptions)

Invokes a duplex streaming call asynchronously. In duplex streaming scenario, client sends a stream of requests and server responds with a stream of responses. The response stream is completely independent and both side can be sending messages at the same time.

Declaration

public override AsyncDuplexStreamingCall<TRequest, TResponse> AsyncDuplexStreamingCall<TRequest, TResponse>(Method<TRequest, TResponse> method, string host, CallOptions options)
    where TRequest : class where TResponse : class

Parameters

Type	Name	Description
Method<TRequest, TResponse>	method
System.String	host
CallOptions	options

Returns

Type	Description
AsyncDuplexStreamingCall<TRequest, TResponse>

Type Parameters

Name	Description
TRequest
TResponse

Overrides

Grpc.Core.CallInvoker.AsyncDuplexStreamingCall<TRequest, TResponse>(Grpc.Core.Method<TRequest, TResponse>, System.String, Grpc.Core.CallOptions)

AsyncServerStreamingCall<TRequest, TResponse>(Method<TRequest, TResponse>, String, CallOptions, TRequest)

Invokes a server streaming call asynchronously. In server streaming scenario, client sends on request and server responds with a stream of responses.

Declaration

public override AsyncServerStreamingCall<TResponse> AsyncServerStreamingCall<TRequest, TResponse>(Method<TRequest, TResponse> method, string host, CallOptions options, TRequest request)
    where TRequest : class where TResponse : class

Parameters

Type	Name	Description
Method<TRequest, TResponse>	method
System.String	host
CallOptions	options
TRequest	request

Returns

Type	Description
AsyncServerStreamingCall<TResponse>

Type Parameters

Name	Description
TRequest
TResponse

Overrides

Grpc.Core.CallInvoker.AsyncServerStreamingCall<TRequest, TResponse>(Grpc.Core.Method<TRequest, TResponse>, System.String, Grpc.Core.CallOptions, TRequest)

AsyncUnaryCall<TRequest, TResponse>(Method<TRequest, TResponse>, String, CallOptions, TRequest)

Invokes a simple remote call asynchronously.

Declaration

public override AsyncUnaryCall<TResponse> AsyncUnaryCall<TRequest, TResponse>(Method<TRequest, TResponse> method, string host, CallOptions options, TRequest request)
    where TRequest : class where TResponse : class

Parameters

Type	Name	Description
Method<TRequest, TResponse>	method
System.String	host
CallOptions	options
TRequest	request

Returns

Type	Description
AsyncUnaryCall<TResponse>

Type Parameters

Name	Description
TRequest
TResponse

Overrides

Grpc.Core.CallInvoker.AsyncUnaryCall<TRequest, TResponse>(Grpc.Core.Method<TRequest, TResponse>, System.String, Grpc.Core.CallOptions, TRequest)

BlockingUnaryCall<TRequest, TResponse>(Method<TRequest, TResponse>, String, CallOptions, TRequest)

Invokes a simple remote call in a blocking fashion.

Declaration

public override TResponse BlockingUnaryCall<TRequest, TResponse>(Method<TRequest, TResponse> method, string host, CallOptions options, TRequest request)
    where TRequest : class where TResponse : class

Parameters

Type	Name	Description
Method<TRequest, TResponse>	method
System.String	host
CallOptions	options
TRequest	request

Returns

Type	Description
TResponse

Type Parameters

Name	Description
TRequest
TResponse

Overrides

Grpc.Core.CallInvoker.BlockingUnaryCall<TRequest, TResponse>(Grpc.Core.Method<TRequest, TResponse>, System.String, Grpc.Core.CallOptions, TRequest)

CreateCall<TRequest, TResponse>(Method<TRequest, TResponse>, String, CallOptions)

Creates call invocation details for given method.

Declaration

protected virtual CallInvocationDetails<TRequest, TResponse> CreateCall<TRequest, TResponse>(Method<TRequest, TResponse> method, string host, CallOptions options)
    where TRequest : class where TResponse : class

Parameters

Type	Name	Description
Method<TRequest, TResponse>	method
System.String	host
CallOptions	options

Returns

Type	Description
CallInvocationDetails<TRequest, TResponse>

Type Parameters

Name	Description
TRequest
TResponse