akka.http.impl.engine.http2

Class BufferedOutlet<T>

java.lang.Object

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

All Implemented Interfaces:

akka.stream.stage.OutHandler

public class BufferedOutlet<T>
extends java.lang.Object
implements akka.stream.stage.OutHandler

INTERNAL API

Constructor Summary

Constructors

Constructor and Description
BufferedOutlet(GenericOutlet<T> outlet)

Method Summary

Modifier and Type	Method and Description
java.util.ArrayDeque<T>	buffer()
void	complete()
boolean	completed()
protected void	doPush(T elem) override to hook into actually pushing, e.g.
void	fail(java.lang.Throwable cause)
void	onPull()
void	push(T elem)
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

$init$, onDownstreamFinish

Constructor Detail

BufferedOutlet

public BufferedOutlet(GenericOutlet<T> outlet)

Method Detail

buffer

public java.util.ArrayDeque<T> buffer()

complete

public void complete()

completed

public boolean completed()

doPush

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

fail

public void fail(java.lang.Throwable cause)

onPull

public void onPull()

Specified by:

onPull in interface akka.stream.stage.OutHandler

push

public void push(T elem)

tryFlush

public void tryFlush()