Package 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 Object
implements akka.stream.stage.OutHandler

INTERNAL API

Constructor Summary

Constructors

Constructor	Description
BufferedOutlet(GenericOutlet<T> outlet)

Method Summary

Modifier and Type	Method	Description
ArrayDeque<T>	buffer()
void	complete()
boolean	completed()
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)
void	fail(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

onDownstreamFinish, onDownstreamFinish

Constructor Details

BufferedOutlet

public BufferedOutlet(GenericOutlet<T> outlet)

Method Details

buffer

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