StreamSPI

The SPI interface for implementing a HTTP/2 stream. This class :{@link Stream} by adding the methods required to implement the HTTP/2 stream functionalities.

interface StreamSPI : Stream , Closeable {

bool isLocal();

SessionSPI getSession();

Listener getListener();

void setListener(Listener listener);

void process(Frame frame, Callback callback);

bool updateClose(bool update, CloseStateEvent event);

void close();

int updateSendWindow(int delta);

int updateRecvWindow(int delta);

bool isRemotelyClosed();

}

Members

Functions

close void close(): Forcibly closes this stream.
getListener Listener getListener(): @return the {@link hunt.http.codec.http.stream.Stream.Listener} associated with this stream @see #setListener(Stream.Listener)
getSession SessionSPI getSession(): Undocumented in source.
isLocal bool isLocal(): @return whether this stream is local or remote
isRemotelyClosed bool isRemotelyClosed(): @return whether the stream is closed remotely. @see #isClosed()
process void process(Frame frame, Callback callback): Processes the given {@code frame}, belonging to this stream.
setListener void setListener(Listener listener): @param listener the {@link hunt.http.codec.http.stream.Stream.Listener} associated with this stream @see #getListener()
updateClose bool updateClose(bool update, CloseStateEvent event): Updates the close state of this stream.
updateRecvWindow int updateRecvWindow(int delta): Updates the stream receive window by the given {@code delta}.
updateSendWindow int updateSendWindow(int delta): Updates the stream send window by the given {@code delta}.

Inherited Members

From Stream

getId int getId(): @return the stream unique id
getSession Session getSession(): @return the session this stream is associated to
headers void headers(HeadersFrame frame, Callback callback): Sends the given HEADERS {@code frame} representing a HTTP response.
push void push(PushPromiseFrame frame, Promise!Stream promise, Listener listener): Sends the given PUSH_PROMISE {@code frame}.
data void data(DataFrame frame, Callback callback): Sends the given DATA {@code frame}.
reset void reset(ResetFrame frame, Callback callback): Sends the given RST_STREAM {@code frame}.
getAttribute Object getAttribute(string key): @param key the attribute key @return an arbitrary object associated with the given key to this stream or null if no object can be found for the given key. @see #setAttribute(string, Object)
setAttribute void setAttribute(string key, Object value): @param key the attribute key @param value an arbitrary object to associate with the given key to this stream @see #getAttribute(string) @see #removeAttribute(string)
removeAttribute Object removeAttribute(string key): @param key the attribute key @return the arbitrary object associated with the given key to this stream @see #setAttribute(string, Object)
isReset bool isReset(): @return whether this stream has been reset
isClosed bool isClosed(): @return whether this stream is closed, both locally and remotely.
toString string toString(): @param idleTimeout the stream idle timeout @see #getIdleTimeout() @see Stream.Listener#onIdleTimeout(Stream, Exception)
Listener interface Listener: A {@link Stream.Listener} is the passive counterpart of a {@link Stream} and receives events happening on a HTTP/2 stream.

StreamSPI

Members

Functions

Inherited Members

From Stream

Meta

Source