ScalaBidirectionalStreamingRequestBuilder

org.apache.pekko.grpc.internal.ScalaBidirectionalStreamingRequestBuilder

@InternalApi

final class ScalaBidirectionalStreamingRequestBuilder[I, O](descriptor: MethodDescriptor[I, O], channel: InternalChannel, defaultOptions: CallOptions, settings: GrpcClientSettings, val headers: MetadataImpl)(implicit ec: ExecutionContext) extends StreamResponseRequestBuilder[Source[I, NotUsed], O], MetadataOperations[ScalaBidirectionalStreamingRequestBuilder[I, O]]

INTERNAL API

Attributes

Source: RequestBuilderImpl.scala
Graph
Supertypes: trait MetadataOperations[ScalaBidirectionalStreamingRequestBuilder[I, O]]

trait StreamResponseRequestBuilder[Source[I, NotUsed], O]

class Object

trait Matchable

class Any

@InternalStableApi

@InternalStableApi

Invoke the gRPC method with the additional metadata added

FIXME for streaming response this doesn't really make sense, left it to keep parity with single response but maybe it should go

Invoke the gRPC method with the additional metadata added and provide access to response metadata

In this article

Generated with