final class JavaBidirectionalStreamingRequestBuilder[I, O] extends StreamResponseRequestBuilder[Source[I, NotUsed], O] with MetadataOperations[JavaBidirectionalStreamingRequestBuilder[I, O]]
Ordering
- Alphabetic
- By Inheritance
Inherited
- JavaBidirectionalStreamingRequestBuilder
- MetadataOperations
- StreamResponseRequestBuilder
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Instance Constructors
- new JavaBidirectionalStreamingRequestBuilder(descriptor: MethodDescriptor[I, O], channel: InternalChannel, defaultOptions: CallOptions, settings: GrpcClientSettings)(implicit ec: ExecutionContext)
- Annotations
- @InternalStableApi()
- new JavaBidirectionalStreamingRequestBuilder(descriptor: MethodDescriptor[I, O], channel: InternalChannel, defaultOptions: CallOptions, settings: GrpcClientSettings, headers: MetadataImpl)(implicit ec: ExecutionContext)
- new JavaBidirectionalStreamingRequestBuilder(descriptor: MethodDescriptor[I, O], fqMethodName: String, channel: InternalChannel, defaultOptions: CallOptions, settings: GrpcClientSettings)(implicit ec: ExecutionContext)
- Annotations
- @deprecated @InternalStableApi()
- Deprecated
(Since version 1.1.0) fqMethodName was removed since it can be derived from the descriptor
Value Members
- def addHeader(key: String, value: ByteString): JavaBidirectionalStreamingRequestBuilder[I, O]
- Definition Classes
- MetadataOperations
- def addHeader(key: String, value: String): JavaBidirectionalStreamingRequestBuilder[I, O]
- Definition Classes
- MetadataOperations
- val headers: MetadataImpl
- Definition Classes
- JavaBidirectionalStreamingRequestBuilder → MetadataOperations
- def invoke(request: Source[I, NotUsed]): Source[O, NotUsed]
Invoke the gRPC method with the additional metadata added
Invoke the gRPC method with the additional metadata added
- Definition Classes
- JavaBidirectionalStreamingRequestBuilder → StreamResponseRequestBuilder
- def invokeWithMetadata(source: Source[I, NotUsed]): Source[O, CompletionStage[GrpcResponseMetadata]]
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
- Definition Classes
- JavaBidirectionalStreamingRequestBuilder → StreamResponseRequestBuilder
- def setDeadline(deadline: Duration): JavaBidirectionalStreamingRequestBuilder[I, O]
Set the deadline for this call
Set the deadline for this call
- returns
A new request builder, that will use the supplied deadline when invoked
- Definition Classes
- JavaBidirectionalStreamingRequestBuilder → StreamResponseRequestBuilder
- def withHeaders(headers: MetadataImpl): JavaBidirectionalStreamingRequestBuilder[I, O]
- Definition Classes
- JavaBidirectionalStreamingRequestBuilder → MetadataOperations