Grpc.Net.Client.Internal.GrpcCall<TRequest, TResponse>

sealed class GrpcCall<TRequest, TResponse> : GrpcCall, IGrpcCall<TRequest, TResponse>, IDisposable, IEnumerable<KeyValuePair<string, object>>, IEnumerable

public object CallWrapper { get; set; }

public HttpContentClientStreamReader<TRequest, TResponse> ClientStreamReader { get; }

public HttpContentClientStreamWriter<TRequest, TResponse> ClientStreamWriter { get; }

public bool Disposed { get; }

public int MessagesRead { get; }

public int MessagesWritten { get; }

public Method<TRequest, TResponse> Method { get; }

public MethodConfigInfo MethodConfig { get; }

public GrpcCall(Method<TRequest, TResponse> method, GrpcMethodInfo grpcMethodInfo, CallOptions options, GrpcChannel channel, int attemptCount, bool forceAsyncHttpResponse)

public void Dispose()

public void EnsureNotDisposed()

public Exception EnsureUserCancellationTokenReported(Exception ex, CancellationToken cancellationToken)

public IEnumerator<KeyValuePair<string, object>> GetEnumerator()

public Task<TResponse> GetResponseAsync()

public Task<Metadata> GetResponseHeadersAsync()

public Status GetStatus()

public Metadata GetTrailers()

public void ResponseStreamEnded(Status status, bool finishedGracefully)

Used by response stream reader to report it is finished.

public void StartClientStreaming()

public void StartDuplexStreaming()

public void StartDuplexStreamingCore(HttpContentClientStreamWriter<TRequest, TResponse> clientStreamWriter, HttpContent content)

public void StartServerStreaming(TRequest request)

public void StartUnary(TRequest request)

public bool TryRegisterCancellation(CancellationToken cancellationToken, out Nullable cancellationTokenRegistration)

public Task WriteClientStreamAsync<TState>(Func<GrpcCall<TRequest, TResponse>, Stream, CallOptions, TState, Task> writeFunc, TState state, CancellationToken cancellationToken)