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