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 java.lang.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
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 akka.stream.stage.OutHandler

onDownstreamFinish, onDownstreamFinish

Constructor Detail

BufferedOutletExtended

public BufferedOutletExtended(GenericOutlet<T> outlet)

Method Detail

buffer

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

doPush

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)

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()