Packages

trait ReadSerializer[I] extends TailStage[I]

Serializes read requests

Source
Serializer.scala
Linear Supertypes
TailStage[I], Tail[I], Stage, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ReadSerializer
  2. TailStage
  3. Tail
  4. Stage
  5. AnyRef
  6. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Abstract Value Members

  1. abstract def name: String
    Definition Classes
    Stage

Concrete Value Members

  1. def channelRead(size: Int = -1, timeout: Duration = Duration.Inf): Future[I]
    Definition Classes
    ReadSerializer → Tail
  2. final def channelWrite(data: Seq[I], timeout: Duration): Future[Unit]
    Definition Classes
    Tail
  3. def channelWrite(data: Seq[I]): Future[Unit]
    Definition Classes
    Tail
  4. final def channelWrite(data: I, timeout: Duration): Future[Unit]
    Definition Classes
    Tail
  5. def channelWrite(data: I): Future[Unit]
    Definition Classes
    Tail
  6. final def closePipeline(cause: Option[Throwable]): Unit
    Definition Classes
    Tail → Stage
  7. final def findOutboundStage[C <: Stage](clazz: Class[C]): Option[C]
    Definition Classes
    Tail
  8. final def findOutboundStage(name: String): Option[Stage]
    Definition Classes
    Tail
  9. def inboundCommand(cmd: InboundCommand): Unit
    Definition Classes
    Stage
  10. final def replaceTail(leafBuilder: LeafBuilder[I], startup: Boolean): ReadSerializer.this.type
    Definition Classes
    Tail
  11. final def spliceBefore(stage: MidStage[I, I]): Unit
    Definition Classes
    Tail