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