AbstractGrpcProtocol

org.apache.pekko.grpc.internal.AbstractGrpcProtocol
See theAbstractGrpcProtocol companion class

Attributes

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

Members list

Type members

Classlikes

class GrpcFramingDecoderStage(codec: Codec, deframe: (Int, ByteString) => Frame)

Attributes

Source
AbstractGrpcProtocol.scala
Supertypes
class GraphStage[FlowShape[ByteString, Frame]]
class GraphStageWithMaterializedValue[FlowShape[ByteString, Frame], NotUsed]
trait Graph[FlowShape[ByteString, Frame], NotUsed]
class Object
trait Matchable
class Any
Show all

Value members

Concrete methods

def encodeFrameData(data: ByteString, isCompressed: Boolean, isTrailer: Boolean): ByteString

Attributes

Source
AbstractGrpcProtocol.scala
def fieldType(codec: Codec): ByteString

Attributes

Source
AbstractGrpcProtocol.scala
def reader(codec: Codec, decodeFrame: (Int, ByteString) => Frame, preDecodeStrict: ByteString => ByteString, preDecodeFlow: Flow[ByteString, ByteString, NotUsed]): GrpcProtocolReader

Attributes

Source
AbstractGrpcProtocol.scala
def writer(protocol: GrpcProtocol, codec: Codec, encodeFrame: Frame => ChunkStreamPart, encodeDataToResponse: (ByteString, Seq[HttpHeader], Trailer) => HttpResponse): GrpcProtocolWriter

Attributes

Source
AbstractGrpcProtocol.scala

Deprecated methods

def encodeFrameData(frameType: ByteString, data: ByteString): ByteString

Attributes

Deprecated
true
Source
AbstractGrpcProtocol.scala