JavaClientStreamingRequestBuilder
org.apache.pekko.grpc.internal.JavaClientStreamingRequestBuilder
@InternalApi
final class JavaClientStreamingRequestBuilder[I, O](descriptor: MethodDescriptor[I, O], channel: InternalChannel, defaultOptions: CallOptions, settings: GrpcClientSettings, val headers: MetadataImpl)(implicit mat: Materializer, ec: ExecutionContext) extends SingleResponseRequestBuilder[Source[I, NotUsed], O], MetadataOperations[JavaClientStreamingRequestBuilder[I, O]]
INTERNAL API
Attributes
- Source
- RequestBuilderImpl.scala
- Graph
-
- Supertypes
-
class Objecttrait Matchableclass Any
Members list
Value members
Constructors
@InternalStableApi
def this(descriptor: MethodDescriptor[I, O], channel: InternalChannel, defaultOptions: CallOptions, settings: GrpcClientSettings)(implicit mat: Materializer, ec: ExecutionContext)
Attributes
- Source
- RequestBuilderImpl.scala
Deprecated constructors
@InternalStableApi
def this(descriptor: MethodDescriptor[I, O], fqMethodName: String, channel: InternalChannel, defaultOptions: CallOptions, settings: GrpcClientSettings)(implicit mat: Materializer, ec: ExecutionContext)
Attributes
- Deprecated
- true
- Source
- RequestBuilderImpl.scala
Concrete methods
Invoke the gRPC method with the additional metadata added
Invoke the gRPC method with the additional metadata added
Attributes
- Definition Classes
- Source
- RequestBuilderImpl.scala
override def invokeWithMetadata(request: Source[I, NotUsed]): CompletionStage[GrpcSingleResponse[O]]
Invoke the gRPC method with the additional metadata added and provide access to response metadata
Invoke the gRPC method with the additional metadata added and provide access to response metadata
Attributes
- Definition Classes
- Source
- RequestBuilderImpl.scala
Attributes
- Definition Classes
- Source
- RequestBuilderImpl.scala
Inherited methods
Attributes
- Inherited from:
- MetadataOperations
- Source
- RequestBuilderImpl.scala
Attributes
- Inherited from:
- MetadataOperations
- Source
- RequestBuilderImpl.scala
Concrete fields
Attributes
- Source
- RequestBuilderImpl.scala
In this article