GrpcResponseHelpers

org.apache.pekko.grpc.internal.GrpcResponseHelpers
@InternalApi

Some helpers for creating HTTP entities for use with gRPC.

INTERNAL API

Attributes

Source
GrpcResponseHelpers.scala
Graph
Supertypes
class Object
trait Matchable
class Any
Self type

Members list

Value members

Concrete methods

def apply[T](e: Source[T, NotUsed])(implicit m: ProtobufSerializer[T], writer: GrpcProtocolWriter, system: ClassicActorSystemProvider): HttpResponse

Attributes

Source
GrpcResponseHelpers.scala
def apply[T](e: Source[T, NotUsed], eHandler: ActorSystem => PartialFunction[Throwable, Trailers])(implicit m: ProtobufSerializer[T], writer: GrpcProtocolWriter, system: ClassicActorSystemProvider): HttpResponse

Attributes

Source
GrpcResponseHelpers.scala
def apply[T](e: Source[T, NotUsed], status: Future[Status])(implicit m: ProtobufSerializer[T], mat: Materializer, writer: GrpcProtocolWriter, system: ClassicActorSystemProvider): HttpResponse

Attributes

Source
GrpcResponseHelpers.scala
def apply[T](e: Source[T, NotUsed], status: Future[Status], eHandler: ActorSystem => PartialFunction[Throwable, Trailers])(implicit m: ProtobufSerializer[T], mat: Materializer, writer: GrpcProtocolWriter, system: ClassicActorSystemProvider): HttpResponse

Attributes

Source
GrpcResponseHelpers.scala
def apply[T](e: Source[T, NotUsed], trail: Source[TrailerFrame, NotUsed], eHandler: ActorSystem => PartialFunction[Throwable, Trailers])(implicit m: ProtobufSerializer[T], writer: GrpcProtocolWriter, system: ClassicActorSystemProvider): HttpResponse

Attributes

Source
GrpcResponseHelpers.scala
def responseForSingleElement[T](e: T, eHandler: ActorSystem => PartialFunction[Throwable, Trailers])(implicit m: ProtobufSerializer[T], writer: GrpcProtocolWriter, system: ClassicActorSystemProvider): HttpResponse

Attributes

Source
GrpcResponseHelpers.scala
def status(trailer: Trailers)(implicit writer: GrpcProtocolWriter): HttpResponse

Attributes

Source
GrpcResponseHelpers.scala