private class HttpReceiver.ContentListeners
extends java.lang.Object
Wraps a list of content listeners, notifies them about content events and tracks individual listener demand to produce a global demand for content.
Modifier and Type | Field and Description |
---|---|
private java.util.function.LongConsumer |
demand |
private java.util.Map<java.lang.Object,java.lang.Long> |
demands |
private java.util.List<Response.DemandedContentListener> |
listeners |
Modifier | Constructor and Description |
---|---|
private |
ContentListeners(java.util.List<Response.ResponseListener> responseListeners) |
Modifier and Type | Method and Description |
---|---|
private void |
accept(java.lang.Object context,
long value) |
private void |
demand(java.lang.Object context,
long value) |
private boolean |
isEmpty() |
private void |
notifyBeforeContent(HttpResponse response) |
private void |
notifyContent(HttpResponse response,
java.nio.ByteBuffer buffer,
Callback callback) |
private final java.util.Map<java.lang.Object,java.lang.Long> demands
private final java.util.function.LongConsumer demand
private final java.util.List<Response.DemandedContentListener> listeners
private ContentListeners(java.util.List<Response.ResponseListener> responseListeners)
private boolean isEmpty()
private void notifyBeforeContent(HttpResponse response)
private void notifyContent(HttpResponse response, java.nio.ByteBuffer buffer, Callback callback)
private void demand(java.lang.Object context, long value)
private void accept(java.lang.Object context, long value)