Class ServerStreamingBase<TResponse>

Base class for server streaming RPC methods.

Inheritance

System.Object

ServerStreamingBase<TResponse>

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: Google.Api.Gax.Grpc

Assembly: Google.Api.Gax.Grpc.dll

Syntax

public class ServerStreamingBase<TResponse>

Type Parameters

Name	Description
TResponse	RPC streaming response type

Properties

GrpcCall

The underlying gRPC duplex streaming call.

Declaration

public virtual AsyncServerStreamingCall<TResponse> GrpcCall { get; }

Property Value

Type	Description
AsyncServerStreamingCall<TResponse>

Methods

GetResponseStream()

Async stream to read streaming responses, exposed as an async sequence. The default implementation will use GrpcCall to extract a response stream, and adapt it to AsyncResponseStream<TResponse>.

Declaration

public virtual AsyncResponseStream<TResponse> GetResponseStream()

Returns

Type	Description
AsyncResponseStream<TResponse>

Remarks

If this method is called more than once, all the returned enumerators will be enumerating over the same underlying response stream, which may cause confusion. Additionally, the sequence returned by this method can only be iterated over a single time. Attempting to iterate more than once will cause an System.InvalidOperationException.