final class ScalaServerStreamingRequestBuilder[I, O] extends StreamResponseRequestBuilder[I, O] with MetadataOperations[ScalaServerStreamingRequestBuilder[I, O]]
Ordering
- Alphabetic
- By Inheritance
Inherited
- ScalaServerStreamingRequestBuilder
- MetadataOperations
- StreamResponseRequestBuilder
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Instance Constructors
- new ScalaServerStreamingRequestBuilder(descriptor: MethodDescriptor[I, O], channel: InternalChannel, defaultOptions: CallOptions, settings: GrpcClientSettings)(implicit ec: ExecutionContext)
- Annotations
- @InternalStableApi()
- new ScalaServerStreamingRequestBuilder(descriptor: MethodDescriptor[I, O], channel: InternalChannel, defaultOptions: CallOptions, settings: GrpcClientSettings, headers: MetadataImpl)(implicit ec: ExecutionContext)
- new ScalaServerStreamingRequestBuilder(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): ScalaServerStreamingRequestBuilder[I, O]
- Definition Classes
- MetadataOperations
- def addHeader(key: String, value: String): ScalaServerStreamingRequestBuilder[I, O]
- Definition Classes
- MetadataOperations
- val headers: MetadataImpl
- Definition Classes
- ScalaServerStreamingRequestBuilder → 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
FIXME for streaming response this doesn't really make sense, left it to keep parity with single response but maybe it should go
- Definition Classes
- ScalaServerStreamingRequestBuilder → StreamResponseRequestBuilder
- def invokeWithMetadata(request: I): Source[O, Future[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
- ScalaServerStreamingRequestBuilder → StreamResponseRequestBuilder
- def setDeadline(deadline: Duration): ScalaServerStreamingRequestBuilder[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
- ScalaServerStreamingRequestBuilder → StreamResponseRequestBuilder
- def withHeaders(headers: MetadataImpl): ScalaServerStreamingRequestBuilder[I, O]
- Definition Classes
- ScalaServerStreamingRequestBuilder → MetadataOperations