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(int id, byte priority, ISession session, IStream associatedStream)

Method Summary

Methods

Modifier and Type	Method and Description
void	associate(IStream stream) Associate the given IStream to this IStream.
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.
void	disassociate(IStream stream) remove the given associated IStream from this stream
IStream	getAssociatedStream() Overrides Stream.getAssociatedStream() to return an instance of IStream instead of Stream
Object	getAttribute(String key)
int	getId()
byte	getPriority()
Set<Stream>	getPushedStreams()
ISession	getSession()
StreamFrameListener	getStreamFrameListener()
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()
boolean	isReset()
boolean	isUnidirectional()
void	process(ControlFrame frame) Processes the given control frame, for example by updating the stream's state or by calling listeners.
void	process(DataInfo dataInfo) Processes the given dataInfo, 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)
Future<Stream>	syn(SynInfo synInfo) Initiate a unidirectional spdy pushstream associated to this stream asynchronously
void	syn(SynInfo synInfo, long timeout, TimeUnit unit, Handler<Stream> handler) Initiate a unidirectional spdy pushstream associated to this stream asynchronously
String	toString()
void	updateCloseState(boolean close, boolean local) 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(int id,
              byte priority,
              ISession session,
              IStream associatedStream)

Method Detail

getId

public int getId()

Specified by:

getId in interface Stream

Returns:

the id of this stream

getAssociatedStream

public IStream getAssociatedStream()

Description copied from interface: IStream

Overrides Stream.getAssociatedStream() to return an instance of IStream instead of Stream

Specified by:

getAssociatedStream in interface Stream

Specified by:

getAssociatedStream in interface IStream

Returns:

the associated parent stream or null if this is not an associated stream

See Also:

Stream.getAssociatedStream()

getPushedStreams

public Set<Stream> getPushedStreams()

Specified by:

getPushedStreams in interface Stream

Returns:

associated child streams or an empty set if no associated streams exist

associate

public void associate(IStream stream)

Description copied from interface: IStream

Associate the given IStream to this IStream.

Specified by:

associate in interface IStream

Parameters:

stream - the stream to associate with this stream

disassociate

public void disassociate(IStream stream)

Description copied from interface: IStream

remove the given associated IStream from this stream

Specified by:

disassociate in interface IStream

Parameters:

stream - the stream to be removed

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 ISession getSession()

Specified by:

getSession in interface Stream

Returns:

the session this stream is associated to

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)

getStreamFrameListener

public StreamFrameListener getStreamFrameListener()

updateCloseState

public void updateCloseState(boolean close,
                    boolean local)

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

local - whether the close is local or remote

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(DataInfo)

process

public void process(DataInfo dataInfo)

Description copied from interface: IStream

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

Specified by:

process in interface IStream

Parameters:

dataInfo - the DataInfo to process

See Also:

IStream.process(ControlFrame)

syn

public Future<Stream> syn(SynInfo synInfo)

Description copied from interface: Stream

Initiate a unidirectional spdy pushstream associated to this stream asynchronously

Callers may use the returned future to get the pushstream once it got created

Specified by:

syn in interface Stream

Parameters:

synInfo - the metadata to send on stream creation

Returns:

a future containing the stream once it got established

See Also:

Stream.syn(SynInfo, long, TimeUnit, Handler)

syn

public void syn(SynInfo synInfo,
       long timeout,
       TimeUnit unit,
       Handler<Stream> handler)

Description copied from interface: Stream

Initiate a unidirectional spdy pushstream associated to this stream asynchronously

Callers may pass a non-null completion handler to be notified of when the pushstream has been established.

Specified by:

syn in interface Stream

Parameters:

synInfo - the metadata to send on stream creation

timeout - the operation's timeout

unit - the timeout's unit

handler - the completion handler that gets notified once the pushstream is established

See Also:

Stream.syn(SynInfo)

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)

isUnidirectional

public boolean isUnidirectional()

Specified by:

isUnidirectional in interface Stream

Returns:

whether this stream is unidirectional or not

isReset

public boolean isReset()

Specified by:

isReset in interface Stream

Returns:

whether this stream has been reset

isHalfClosed

public boolean isHalfClosed()

Specified by:

isHalfClosed in interface Stream

Returns:

whether this stream has been closed by one party only

See Also:

Stream.isClosed()

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