org.eclipse.jetty.spdy

Class StandardStream

java.lang.Object

org.eclipse.jetty.spdy.StandardStream

All Implemented Interfaces:

Stream, IStream

public class StandardStream
extends Object
implements IStream

Constructor Summary

Constructors

Constructor and Description
StandardStream(SynStreamFrame frame, ISession session, int windowSize)

Method Summary

Methods

Modifier and Type	Method and Description
Future<Void>	data(DataInfo dataInfo) Sends asynchronously a DATA frame on this stream.
void	data(DataInfo dataInfo, long timeout, TimeUnit unit, Handler<Void> handler) Sends asynchronously a DATA frame on this stream.
Object	getAttribute(String key)
int	getId()
byte	getPriority()
Session	getSession()
int	getWindowSize() Senders of data frames need to know the current window size to determine whether they can send more data.
Future<Void>	headers(HeadersInfo headersInfo) Sends asynchronously a HEADER frame on this stream.
void	headers(HeadersInfo headersInfo, long timeout, TimeUnit unit, Handler<Void> handler) Sends asynchronously a HEADER frame on this stream.
boolean	isClosed()
boolean	isHalfClosed()
void	process(ControlFrame frame) Processes the given control frame, for example by updating the stream's state or by calling listeners.
void	process(DataFrame frame, ByteBuffer data) Processes the give data frame along with the given byte buffer, for example by updating the stream's state or by calling listeners.
Object	removeAttribute(String key)
Future<Void>	reply(ReplyInfo replyInfo) Sends asynchronously a SYN_REPLY frame in response to a SYN_STREAM frame.
void	reply(ReplyInfo replyInfo, long timeout, TimeUnit unit, Handler<Void> handler) Sends asynchronously a SYN_REPLY frame in response to a SYN_STREAM frame.
void	setAttribute(String key, Object value)
void	setStreamFrameListener(StreamFrameListener listener)
String	toString()
void	updateCloseState(boolean close) A stream can be open, half closed or closed and this method updates the close state of this stream.
void	updateWindowSize(int delta) Updates the window size for this stream by the given amount, that can be positive or negative.

Methods inherited from class java.lang.Object

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

Constructor Detail

StandardStream

public StandardStream(SynStreamFrame frame,
              ISession session,
              int windowSize)

Method Detail

getId

public int getId()

Specified by:

getId in interface Stream

Returns:

the id of this stream

getPriority

public byte getPriority()

Specified by:

getPriority in interface Stream

Returns:

the priority of this stream

getWindowSize

public int getWindowSize()

Description copied from interface: IStream

Senders of data frames need to know the current window size to determine whether they can send more data.

Specified by:

getWindowSize in interface IStream

Returns:

the current window size for this stream.

See Also:

IStream.updateWindowSize(int)

updateWindowSize

public void updateWindowSize(int delta)

Description copied from interface: IStream

Updates the window size for this stream by the given amount, that can be positive or negative.

Senders and recipients of data frames update the window size, respectively, with negative values and positive values.

Specified by:

updateWindowSize in interface IStream

Parameters:

delta - the signed amount the window size needs to be updated

See Also:

IStream.getWindowSize()

getSession

public Session getSession()

Specified by:

getSession in interface Stream

Returns:

the session this stream is associated to

isHalfClosed

public boolean isHalfClosed()

Specified by:

isHalfClosed in interface Stream

Returns:

whether this stream has been closed by one party only

See Also:

* @param timeout the timeout for the stream creation

getAttribute

public Object getAttribute(String key)

Specified by:

getAttribute in interface Stream

Parameters:

key - the attribute key

Returns:

an arbitrary object associated with the given key to this stream

See Also:

Stream.setAttribute(String, Object)

setAttribute

public void setAttribute(String key,
                Object value)

Specified by:

setAttribute in interface Stream

Parameters:

key - the attribute key

value - an arbitrary object to associate with the given key to this stream

See Also:

Stream.getAttribute(String), Stream.removeAttribute(String)

removeAttribute

public Object removeAttribute(String key)

Specified by:

removeAttribute in interface Stream

Parameters:

key - the attribute key

Returns:

the arbitrary object associated with the given key to this stream

See Also:

Stream.setAttribute(String, Object)

setStreamFrameListener

public void setStreamFrameListener(StreamFrameListener listener)

Specified by:

setStreamFrameListener in interface IStream

Parameters:

listener - the stream frame listener associated to this stream as returned by SessionFrameListener.onSyn(Stream, SynInfo)

updateCloseState

public void updateCloseState(boolean close)

Description copied from interface: IStream

A stream can be open, half closed or closed and this method updates the close state of this stream.

If the stream is open, calling this method with a value of true puts the stream into half closed state.

If the stream is half closed, calling this method with a value of true puts the stream into closed state.

Specified by:

updateCloseState in interface IStream

Parameters:

close - whether the close state should be updated

process

public void process(ControlFrame frame)

Description copied from interface: IStream

Processes the given control frame, for example by updating the stream's state or by calling listeners.

Specified by:

process in interface IStream

Parameters:

frame - the control frame to process

See Also:

IStream.process(DataFrame, ByteBuffer)

process

public void process(DataFrame frame,
           ByteBuffer data)

Description copied from interface: IStream

Processes the give data frame along with the given byte buffer, for example by updating the stream's state or by calling listeners.

Specified by:

process in interface IStream

Parameters:

frame - the data frame to process

data - the byte buffer to process

See Also:

IStream.process(ControlFrame)

reply

public Future<Void> reply(ReplyInfo replyInfo)

Description copied from interface: Stream

Sends asynchronously a SYN_REPLY frame in response to a SYN_STREAM frame.

Callers may use the returned future to wait for the reply to be actually sent.

Specified by:

reply in interface Stream

Parameters:

replyInfo - the metadata to send

Returns:

a future to wait for the reply to be sent

See Also:

Stream.reply(ReplyInfo, long, TimeUnit, Handler), SessionFrameListener.onSyn(Stream, SynInfo)

reply

public void reply(ReplyInfo replyInfo,
         long timeout,
         TimeUnit unit,
         Handler<Void> handler)

Description copied from interface: Stream

Sends asynchronously a SYN_REPLY frame in response to a SYN_STREAM frame.

Callers may pass a non-null completion handler to be notified of when the reply has been actually sent.

Specified by:

reply in interface Stream

Parameters:

replyInfo - the metadata to send

timeout - the operation's timeout

unit - the timeout's unit

handler - the completion handler that gets notified of reply sent

See Also:

Stream.reply(ReplyInfo)

data

public Future<Void> data(DataInfo dataInfo)

Description copied from interface: Stream

Sends asynchronously a DATA frame on this stream.

DATA frames should always be sent after a SYN_REPLY frame.

Callers may use the returned future to wait for the data to be actually sent.

Specified by:

data in interface Stream

Parameters:

dataInfo - the metadata to send

Returns:

a future to wait for the data to be sent

See Also:

Stream.data(DataInfo, long, TimeUnit, Handler), Stream.reply(ReplyInfo)

data

public void data(DataInfo dataInfo,
        long timeout,
        TimeUnit unit,
        Handler<Void> handler)

Description copied from interface: Stream

Sends asynchronously a DATA frame on this stream.

DATA frames should always be sent after a SYN_REPLY frame.

Callers may pass a non-null completion handler to be notified of when the data has been actually sent.

Specified by:

data in interface Stream

Parameters:

dataInfo - the metadata to send

timeout - the operation's timeout

unit - the timeout's unit

handler - the completion handler that gets notified of data sent

See Also:

Stream.data(DataInfo)

headers

public Future<Void> headers(HeadersInfo headersInfo)

Description copied from interface: Stream

Sends asynchronously a HEADER frame on this stream.

HEADERS frames should always be sent after a SYN_REPLY frame.

Callers may use the returned future to wait for the headers to be actually sent.

Specified by:

headers in interface Stream

Parameters:

headersInfo - the metadata to send

Returns:

a future to wait for the headers to be sent

See Also:

Stream.headers(HeadersInfo, long, TimeUnit, Handler), Stream.reply(ReplyInfo)

headers

public void headers(HeadersInfo headersInfo,
           long timeout,
           TimeUnit unit,
           Handler<Void> handler)

Description copied from interface: Stream

Sends asynchronously a HEADER frame on this stream.

HEADERS frames should always be sent after a SYN_REPLY frame.

Callers may pass a non-null completion handler to be notified of when the headers have been actually sent.

Specified by:

headers in interface Stream

Parameters:

headersInfo - the metadata to send

timeout - the operation's timeout

unit - the timeout's unit

handler - the completion handler that gets notified of headers sent

See Also:

Stream.headers(HeadersInfo)

isClosed

public boolean isClosed()

Specified by:

isClosed in interface Stream

Returns:

whether this stream has been closed by both parties

See Also:

Stream.isHalfClosed()

toString

public String toString()

Overrides:

toString in class Object