Packages

c

akka.grpc.GrpcProtocol

GrpcProtocolReader

case class GrpcProtocolReader(messageEncoding: Codec, decodeSingleFrame: (ByteString) ⇒ ByteString, frameDecoder: Flow[ByteString, Frame, NotUsed]) extends Product with Serializable

Implements the decoding of the gRPC framing from a physical/transport layer.

Source
GrpcProtocol.scala
Linear Supertypes
Serializable, Serializable, Product, Equals, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. GrpcProtocolReader
  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 GrpcProtocolReader(messageEncoding: Codec, decodeSingleFrame: (ByteString) ⇒ ByteString, frameDecoder: Flow[ByteString, Frame, NotUsed])

Value Members

  1. val dataFrameDecoder: Flow[ByteString, ByteString, NotUsed]

    A Flow of Frames over a stream of messages encoded in gRPC framing that only expects data frames, and produces the body of each data frame.

    A Flow of Frames over a stream of messages encoded in gRPC framing that only expects data frames, and produces the body of each data frame. This flow will throw IllegalStateException if anything other than a data frame is encountered.

  2. val decodeSingleFrame: (ByteString) ⇒ ByteString
  3. val frameDecoder: Flow[ByteString, Frame, NotUsed]
  4. val messageEncoding: Codec