BufferedOutletExtended

public class BufferedOutletExtended<T>
extends java.lang.Object
implements org.apache.pekko.stream.stage.OutHandler

INTERNAL API

Nested Classes
Modifier and Type	Class and Description
`class`	`BufferedOutletExtended.ElementAndTrigger`
`class`	`BufferedOutletExtended.ElementAndTrigger$`

Constructors
Constructor and Description
`BufferedOutletExtended(GenericOutlet<T> outlet)`

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`java.util.ArrayDeque<BufferedOutletExtended.ElementAndTrigger>`	`buffer()`
`protected void`	`doPush(BufferedOutletExtended.ElementAndTrigger elem)` override to hook into actually pushing, e.g. to keep track how much has been pushed already (in contract, to being still cached)
`void`	`onPull()`
`void`	`push(T element)`
`void`	`pushWithTrigger(T elem, scala.Function0<scala.runtime.BoxedUnit> trigger)`
`void`	`tryFlush()`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.pekko.stream.stage.OutHandler
$init$, onDownstreamFinish, onDownstreamFinish

public BufferedOutletExtended(GenericOutlet<T> outlet)

public final java.util.ArrayDeque<BufferedOutletExtended.ElementAndTrigger> buffer()

public final void pushWithTrigger(T elem,
                                  scala.Function0<scala.runtime.BoxedUnit> trigger)

Class BufferedOutletExtended<T>