GrpcFramingDecoderStage

class GrpcFramingDecoderStage extends ByteStringParser[Frame]

Source: AbstractGrpcProtocol.scala

Linear Supertypes

ByteStringParser[Frame], GraphStage[FlowShape[ByteString, Frame]], GraphStageWithMaterializedValue[FlowShape[ByteString, Frame], NotUsed], Graph[FlowShape[ByteString, Frame], NotUsed], AnyRef, Any

Ordering

Alphabetic
By Inheritance

Inherited

GrpcFramingDecoderStage
ByteStringParser
GraphStage
GraphStageWithMaterializedValue
Graph
AnyRef
Any

Hide All
Show All

Visibility

Public
All

Instance Constructors

new GrpcFramingDecoderStage(codec: Codec, deframe: (Int, ByteString) ⇒ Frame)

Type Members

class ParsingLogic extends GraphStageLogic with InHandler with OutHandler

Definition Classes
ByteStringParser
type Shape = FlowShape[ByteString, Frame]

Definition Classes
Graph

Value Members

final def !=(arg0: Any): Boolean

Definition Classes
AnyRef → Any
final def ##(): Int

Definition Classes
AnyRef → Any
final def ==(arg0: Any): Boolean

Definition Classes
AnyRef → Any
def addAttributes(attr: Attributes): Graph[FlowShape[ByteString, Frame], NotUsed]

Definition Classes
Graph
final def asInstanceOf[T0]: T0

Definition Classes
Any
def async(dispatcher: String, inputBufferSize: Int): Graph[FlowShape[ByteString, Frame], NotUsed]

Definition Classes
Graph
def async(dispatcher: String): Graph[FlowShape[ByteString, Frame], NotUsed]

Definition Classes
Graph
def async: Graph[FlowShape[ByteString, Frame], NotUsed]

Definition Classes
Graph
def clone(): AnyRef

Attributes
protected[lang]
Definition Classes
AnyRef
Annotations
@throws( ... ) @native()
def createLogic(inheritedAttributes: Attributes): GraphStageLogic

Definition Classes
GrpcFramingDecoderStage → GraphStage
final def createLogicAndMaterializedValue(inheritedAttributes: Attributes): (GraphStageLogic, NotUsed)

Definition Classes
GraphStage → GraphStageWithMaterializedValue
final def eq(arg0: AnyRef): Boolean

Definition Classes
AnyRef
def equals(arg0: Any): Boolean

Definition Classes
AnyRef → Any
def finalize(): Unit

Attributes
protected[lang]
Definition Classes
AnyRef
Annotations
@throws( classOf[java.lang.Throwable] )
final def getClass(): Class[_]

Definition Classes
AnyRef → Any
Annotations
@native()
def hashCode(): Int

Definition Classes
AnyRef → Any
Annotations
@native()
def initialAttributes: Attributes

Definition Classes
ByteStringParser → GraphStageWithMaterializedValue
final def isInstanceOf[T0]: Boolean

Definition Classes
Any
def named(name: String): Graph[FlowShape[ByteString, Frame], NotUsed]

Definition Classes
Graph
final def ne(arg0: AnyRef): Boolean

Definition Classes
AnyRef
final def notify(): Unit

Definition Classes
AnyRef
Annotations
@native()
final def notifyAll(): Unit

Definition Classes
AnyRef
Annotations
@native()
final val shape: FlowShape[ByteString, Frame]

Definition Classes
ByteStringParser → Graph
final def synchronized[T0](arg0: ⇒ T0): T0

Definition Classes
AnyRef
def toString(): String

Definition Classes
AnyRef → Any
final def wait(): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
final def wait(arg0: Long, arg1: Int): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
final def wait(arg0: Long): Unit

Definition Classes
AnyRef
Annotations
@throws( ... ) @native()
final def withAttributes(attr: Attributes): Graph[FlowShape[ByteString, Frame], NotUsed]

Definition Classes
GraphStageWithMaterializedValue → Graph

Inherited from ByteStringParser[Frame]

Value Members

def initialAttributes: Attributes

Definition Classes
ByteStringParser → GraphStageWithMaterializedValue
final val shape: FlowShape[ByteString, Frame]

Definition Classes
ByteStringParser → Graph

Inherited from GraphStage[FlowShape[ByteString, Frame]]

Value Members

final def createLogicAndMaterializedValue(inheritedAttributes: Attributes): (GraphStageLogic, NotUsed)

Definition Classes
GraphStage → GraphStageWithMaterializedValue

Inherited from GraphStageWithMaterializedValue[FlowShape[ByteString, Frame], NotUsed]

Value Members

final def withAttributes(attr: Attributes): Graph[FlowShape[ByteString, Frame], NotUsed]

Definition Classes
GraphStageWithMaterializedValue → Graph

Inherited from Graph[FlowShape[ByteString, Frame], NotUsed]

Value Members

def addAttributes(attr: Attributes): Graph[FlowShape[ByteString, Frame], NotUsed]

Definition Classes
Graph
def async(dispatcher: String, inputBufferSize: Int): Graph[FlowShape[ByteString, Frame], NotUsed]

Definition Classes
Graph
def async(dispatcher: String): Graph[FlowShape[ByteString, Frame], NotUsed]

Definition Classes
Graph
def async: Graph[FlowShape[ByteString, Frame], NotUsed]

Definition Classes
Graph
def named(name: String): Graph[FlowShape[ByteString, Frame], NotUsed]

Definition Classes
Graph

Inherited from AnyRef

Value Members

final def !=(arg0: Any): Boolean

Definition Classes
AnyRef → Any
final def ##(): Int

Definition Classes
AnyRef → Any
final def ==(arg0: Any): Boolean

Definition Classes
AnyRef → Any
def clone(): AnyRef

Attributes
protected[lang]
Definition Classes
AnyRef
Annotations
@throws( ... ) @native()
final def eq(arg0: AnyRef): Boolean

Definition Classes
AnyRef
def equals(arg0: Any): Boolean

Definition Classes
AnyRef → Any
def finalize(): Unit

Attributes
protected[lang]
Definition Classes
AnyRef
Annotations
@throws( classOf[java.lang.Throwable] )
final def getClass(): Class[_]

Definition Classes
AnyRef → Any
Annotations
@native()
def hashCode(): Int

Definition Classes
AnyRef → Any
Annotations
@native()
final def ne(arg0: AnyRef): Boolean

Definition Classes
AnyRef
final def notify(): Unit

Definition Classes
AnyRef
Annotations
@native()
final def notifyAll(): Unit

Definition Classes
AnyRef
Annotations
@native()
final def synchronized[T0](arg0: ⇒ T0): T0

Definition Classes
AnyRef
def toString(): String

Definition Classes
AnyRef → Any
final def wait(): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
final def wait(arg0: Long, arg1: Int): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
final def wait(arg0: Long): Unit

Definition Classes
AnyRef
Annotations
@throws( ... ) @native()

Inherited from Any

Value Members

final def asInstanceOf[T0]: T0

Definition Classes
Any
final def isInstanceOf[T0]: Boolean

Definition Classes
Any

Ungrouped

class ParsingLogic extends GraphStageLogic with InHandler with OutHandler

Definition Classes
ByteStringParser
type Shape = FlowShape[ByteString, Frame]

Definition Classes
Graph

final def !=(arg0: Any): Boolean

Definition Classes
AnyRef → Any
final def ##(): Int

Definition Classes
AnyRef → Any
final def ==(arg0: Any): Boolean

Definition Classes
AnyRef → Any
def addAttributes(attr: Attributes): Graph[FlowShape[ByteString, Frame], NotUsed]

Definition Classes
Graph
final def asInstanceOf[T0]: T0

Definition Classes
Any
def async(dispatcher: String, inputBufferSize: Int): Graph[FlowShape[ByteString, Frame], NotUsed]

Definition Classes
Graph
def async(dispatcher: String): Graph[FlowShape[ByteString, Frame], NotUsed]

Definition Classes
Graph
def async: Graph[FlowShape[ByteString, Frame], NotUsed]

Definition Classes
Graph
def clone(): AnyRef

Attributes
protected[lang]
Definition Classes
AnyRef
Annotations
@throws( ... ) @native()
def createLogic(inheritedAttributes: Attributes): GraphStageLogic

Definition Classes
GrpcFramingDecoderStage → GraphStage
final def createLogicAndMaterializedValue(inheritedAttributes: Attributes): (GraphStageLogic, NotUsed)

Definition Classes
GraphStage → GraphStageWithMaterializedValue
final def eq(arg0: AnyRef): Boolean

Definition Classes
AnyRef
def equals(arg0: Any): Boolean

Definition Classes
AnyRef → Any
def finalize(): Unit

Attributes
protected[lang]
Definition Classes
AnyRef
Annotations
@throws( classOf[java.lang.Throwable] )
final def getClass(): Class[_]

Definition Classes
AnyRef → Any
Annotations
@native()
def hashCode(): Int

Definition Classes
AnyRef → Any
Annotations
@native()
def initialAttributes: Attributes

Definition Classes
ByteStringParser → GraphStageWithMaterializedValue
final def isInstanceOf[T0]: Boolean

Definition Classes
Any
def named(name: String): Graph[FlowShape[ByteString, Frame], NotUsed]

Definition Classes
Graph
final def ne(arg0: AnyRef): Boolean

Definition Classes
AnyRef
final def notify(): Unit

Definition Classes
AnyRef
Annotations
@native()
final def notifyAll(): Unit

Definition Classes
AnyRef
Annotations
@native()
final val shape: FlowShape[ByteString, Frame]

Definition Classes
ByteStringParser → Graph
final def synchronized[T0](arg0: ⇒ T0): T0

Definition Classes
AnyRef
def toString(): String

Definition Classes
AnyRef → Any
final def wait(): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
final def wait(arg0: Long, arg1: Int): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
final def wait(arg0: Long): Unit

Definition Classes
AnyRef
Annotations
@throws( ... ) @native()
final def withAttributes(attr: Attributes): Graph[FlowShape[ByteString, Frame], NotUsed]

Definition Classes
GraphStageWithMaterializedValue → Graph

Packages

GrpcFramingDecoderStage 

class GrpcFramingDecoderStage extends ByteStringParser[Frame]

Instance Constructors

Type Members

Value Members

Inherited from ByteStringParser[Frame]

Value Members

Inherited from GraphStage[FlowShape[ByteString, Frame]]

Value Members

Inherited from GraphStageWithMaterializedValue[FlowShape[ByteString, Frame], NotUsed]

Value Members

Inherited from Graph[FlowShape[ByteString, Frame], NotUsed]

Value Members

Inherited from AnyRef

Value Members

Inherited from Any

Value Members

Ungrouped

GrpcFramingDecoderStage