BufferedOutlet

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 Description

BufferedOutlet(GenericOutlet<T> outlet)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	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 akka.stream.stage.OutHandler
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 akka.stream.stage.OutHandler
  - push
```
public void push(T elem)
```
  - tryFlush
```
public void tryFlush()
```