org.apache.pekko.http.impl.engine.http2

Class BufferedOutlet<T>

java.lang.Object

org.apache.pekko.http.impl.engine.http2.BufferedOutlet<T>

All Implemented Interfaces:

org.apache.pekko.stream.stage.OutHandler

public class BufferedOutlet<T>
extends java.lang.Object
implements org.apache.pekko.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. to keep track how much has been pushed already (in contract, to being still cached)
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 org.apache.pekko.stream.stage.OutHandler

$init$, onDownstreamFinish, 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 org.apache.pekko.stream.stage.OutHandler

push

public void push(T elem)

tryFlush

public void tryFlush()