Packages

c

akka.grpc.GrpcProtocol

GrpcProtocolWriter

case class GrpcProtocolWriter(contentType: ContentType, messageEncoding: Codec, encodeFrame: (Frame) ⇒ ChunkStreamPart, encodeDataToResponse: (ByteString, Seq[HttpHeader], Trailer) ⇒ HttpResponse, frameEncoder: Flow[Frame, ChunkStreamPart, NotUsed]) extends Product with Serializable

Implements the encoding of a stream of gRPC Frames into a physical/transport layer.

This maps the logical gRPC frames into a stream of chunks that can be handled by the HTTP/2 or HTTP/1.1 transport layer.

Source
GrpcProtocol.scala
Linear Supertypes
Serializable, Serializable, Product, Equals, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. GrpcProtocolWriter
  2. Serializable
  3. Serializable
  4. Product
  5. Equals
  6. AnyRef
  7. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new GrpcProtocolWriter(contentType: ContentType, messageEncoding: Codec, encodeFrame: (Frame) ⇒ ChunkStreamPart, encodeDataToResponse: (ByteString, Seq[HttpHeader], Trailer) ⇒ HttpResponse, frameEncoder: Flow[Frame, ChunkStreamPart, NotUsed])

Value Members

  1. val contentType: ContentType
  2. val encodeDataToResponse: (ByteString, Seq[HttpHeader], Trailer) ⇒ HttpResponse
  3. val encodeFrame: (Frame) ⇒ ChunkStreamPart
  4. val frameEncoder: Flow[Frame, ChunkStreamPart, NotUsed]
  5. val messageEncoding: Codec