Apache Pekko gRPC
1.0.2
API
Generated with
Apache Pekko gRPC/org.apache.pekko.grpc/org.apache.pekko.grpc.internal/ScalaClientStreamingRequestBuilder

ScalaClientStreamingRequestBuilder

org.apache.pekko.grpc.internal.ScalaClientStreamingRequestBuilder
@InternalApi
final class ScalaClientStreamingRequestBuilder[I, O](descriptor: MethodDescriptor[I, O], channel: InternalChannel, defaultOptions: CallOptions, settings: GrpcClientSettings, val headers: MetadataImpl)(implicit mat: Materializer, ec: ExecutionContext) extends SingleResponseRequestBuilder[Source[I, NotUsed], O], MetadataOperations[ScalaClientStreamingRequestBuilder[I, O]]

INTERNAL API

Attributes

Source
RequestBuilderImpl.scala
Graph
Supertypes
trait SingleResponseRequestBuilder[Source[I, NotUsed], O]
class Object
trait Matchable
class Any

Members list

Value members

Constructors

@InternalStableApi
def this(descriptor: MethodDescriptor[I, O], channel: InternalChannel, defaultOptions: CallOptions, settings: GrpcClientSettings)(implicit mat: Materializer, ec: ExecutionContext)

Attributes

Source
RequestBuilderImpl.scala

Deprecated constructors

@InternalStableApi
def this(descriptor: MethodDescriptor[I, O], fqMethodName: String, channel: InternalChannel, defaultOptions: CallOptions, settings: GrpcClientSettings)(implicit mat: Materializer, ec: ExecutionContext)

Attributes

Deprecated
true
Source
RequestBuilderImpl.scala

Concrete methods

override 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

Attributes

Definition Classes
Source
RequestBuilderImpl.scala
override 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

Attributes

Definition Classes
Source
RequestBuilderImpl.scala
override def withHeaders(headers: MetadataImpl): ScalaClientStreamingRequestBuilder[I, O]

Attributes

Definition Classes
Source
RequestBuilderImpl.scala

Inherited methods

def addHeader(key: String, value: ByteString): T

Attributes

Inherited from:
MetadataOperations
Source
RequestBuilderImpl.scala
def addHeader(key: String, value: String): T

Attributes

Inherited from:
MetadataOperations
Source
RequestBuilderImpl.scala

Concrete fields

val headers: MetadataImpl

Attributes

Source
RequestBuilderImpl.scala
Generated with