final class JavaClientStreamingRequestBuilder[I, O] extends SingleResponseRequestBuilder[Source[I, NotUsed], O] with MetadataOperations[JavaClientStreamingRequestBuilder[I, O]]
Ordering
- Alphabetic
- By Inheritance
Inherited
- JavaClientStreamingRequestBuilder
- MetadataOperations
- SingleResponseRequestBuilder
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- All
Instance Constructors
-
new
JavaClientStreamingRequestBuilder(descriptor: MethodDescriptor[I, O], channel: InternalChannel, defaultOptions: CallOptions, settings: GrpcClientSettings)(implicit mat: Materializer, ec: ExecutionContext)
- Annotations
- @InternalStableApi()
- new JavaClientStreamingRequestBuilder(descriptor: MethodDescriptor[I, O], channel: InternalChannel, defaultOptions: CallOptions, settings: GrpcClientSettings, headers: MetadataImpl)(implicit mat: Materializer, ec: ExecutionContext)
-
new
JavaClientStreamingRequestBuilder(descriptor: MethodDescriptor[I, O], fqMethodName: String, channel: InternalChannel, defaultOptions: CallOptions, settings: GrpcClientSettings)(implicit mat: Materializer, 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): JavaClientStreamingRequestBuilder[I, O]
- Definition Classes
- MetadataOperations
-
def
addHeader(key: String, value: String): JavaClientStreamingRequestBuilder[I, O]
- Definition Classes
- MetadataOperations
-
val
headers: MetadataImpl
- Definition Classes
- JavaClientStreamingRequestBuilder → MetadataOperations
-
def
invoke(request: Source[I, NotUsed]): CompletionStage[O]
Invoke the gRPC method with the additional metadata added
Invoke the gRPC method with the additional metadata added
- Definition Classes
- JavaClientStreamingRequestBuilder → SingleResponseRequestBuilder
-
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
- Definition Classes
- JavaClientStreamingRequestBuilder → SingleResponseRequestBuilder
-
def
withHeaders(headers: MetadataImpl): JavaClientStreamingRequestBuilder[I, O]
- Definition Classes
- JavaClientStreamingRequestBuilder → MetadataOperations