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
All Methods Instance Methods Concrete Methods 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.
-
-
-
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)
-
-