Package org.eclipse.jetty.http2.client.http

Class HttpReceiverOverHTTP2.ContentNotifier

java.lang.Object

org.eclipse.jetty.http2.client.http.HttpReceiverOverHTTP2.ContentNotifier

Enclosing class:

HttpReceiverOverHTTP2

private class HttpReceiverOverHTTP2.ContentNotifier
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private class	HttpReceiverOverHTTP2.ContentNotifier.DataInfo

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	active
private HttpReceiverOverHTTP2.ContentNotifier.DataInfo	dataInfo
private java.util.Queue<HttpReceiverOverHTTP2.ContentNotifier.DataInfo>	queue
private HttpReceiverOverHTTP2	receiver
private boolean	resume
private boolean	stalled

Constructor Summary

Constructors

Modifier	Constructor	Description
private	ContentNotifier(HttpReceiverOverHTTP2 receiver)

Method Summary

Modifier and Type	Method	Description
private boolean	active(boolean resume)
private void	enqueue(HttpReceiverOverHTTP2.ContentNotifier.DataInfo dataInfo)
private void	fail(org.eclipse.jetty.util.Callback callback, java.lang.Throwable failure)
private void	offer(org.eclipse.jetty.client.HttpExchange exchange, DataFrame frame, org.eclipse.jetty.util.Callback callback)
private void	process(boolean resume)
private void	reset()
private boolean	stall()	Called when there is no demand, this method checks whether the processing should really stop or it should continue.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

queue

private final java.util.Queue<HttpReceiverOverHTTP2.ContentNotifier.DataInfo> queue

receiver

private final HttpReceiverOverHTTP2 receiver

dataInfo

private HttpReceiverOverHTTP2.ContentNotifier.DataInfo dataInfo

active

private boolean active

resume

private boolean resume

stalled

private boolean stalled

Constructor Detail

ContentNotifier

private ContentNotifier(HttpReceiverOverHTTP2 receiver)

Method Detail

offer

private void offer(org.eclipse.jetty.client.HttpExchange exchange,
                   DataFrame frame,
                   org.eclipse.jetty.util.Callback callback)

enqueue

private void enqueue(HttpReceiverOverHTTP2.ContentNotifier.DataInfo dataInfo)

process

private void process(boolean resume)

active

private boolean active(boolean resume)

stall

private boolean stall()

Called when there is no demand, this method checks whether the processing should really stop or it should continue.

Returns:

true to stop processing, false to continue processing

reset

private void reset()

fail

private void fail(org.eclipse.jetty.util.Callback callback,
                  java.lang.Throwable failure)