Package akka.http.impl.engine.http2

Class BufferedOutletExtended<T>

java.lang.Object

akka.http.impl.engine.http2.BufferedOutletExtended<T>

All Implemented Interfaces:

akka.stream.stage.OutHandler

public class BufferedOutletExtended<T>
extends Object
implements akka.stream.stage.OutHandler

INTERNAL API

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	BufferedOutletExtended.ElementAndTrigger
class	BufferedOutletExtended.ElementAndTrigger$

Constructor Summary

Constructors

Constructor	Description
BufferedOutletExtended(GenericOutlet<T> outlet)

Method Summary

Modifier and Type	Method	Description
final ArrayDeque<BufferedOutletExtended<T>.ElementAndTrigger>	buffer()
protected void	doPush(BufferedOutletExtended<T>.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()
final void	push(T element)
final 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 akka.stream.stage.OutHandler

onDownstreamFinish, onDownstreamFinish

Constructor Details

BufferedOutletExtended

public BufferedOutletExtended(GenericOutlet<T> outlet)

Method Details

buffer

public final ArrayDeque<BufferedOutletExtended<T>.ElementAndTrigger> buffer()

doPush

protected void doPush(BufferedOutletExtended<T>.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)

Parameters:

elem - (undocumented)

onPull

public void onPull()

Specified by:

onPull in interface akka.stream.stage.OutHandler

push

public final void push(T element)

pushWithTrigger

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

tryFlush

public void tryFlush()