org.glassfish.grizzly.spdy

Class SpdyStream

java.lang.Object

org.glassfish.grizzly.spdy.SpdyStream

All Implemented Interfaces:

AttributeStorage, Closeable, OutputSink

public class SpdyStream
extends Object
implements AttributeStorage, OutputSink, Closeable

The abstraction representing SPDY stream.

Author:

Grizzly team

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	SpdyStream.Termination
protected static class	SpdyStream.TerminationType

Field Summary

Fields

Modifier and Type	Field and Description
static String	SPDY_STREAM_ATTRIBUTE

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	SpdyStream(SpdySession spdySession, HttpRequestPacket spdyRequest, int streamId, int associatedToStreamId, int priority, int slot, boolean isUnidirectional)

Method Summary

Modifier and Type	Method and Description
void	addCloseListener(CloseListener closeListener) Add the CloseListener, which will be notified once the stream will be closed.
PushResource	addPushResource(String url, PushResource pushResource)
void	assertOpen() Checks if this Closeable is open and ready to be used.
boolean	canWrite()
boolean	canWrite(int length) Deprecated.
GrizzlyFuture<Closeable>	close() Gracefully (if supported by the implementation) closes this stream and releases any system resources associated with it.
void	close(CompletionHandler<Closeable> completionHandler) Deprecated. please use close() with the following GrizzlyFuture.addCompletionHandler(org.glassfish.grizzly.CompletionHandler) call
GrizzlyFuture<CloseReason>	closeFuture()
void	closeSilently() Gracefully (if supported by the implementation) closes this stream and releases any system resources associated with it.
void	closeWithReason(IOException cause) Gracefully closes the Closeable and provides the reason description.
int	getAssociatedToStreamId()
AttributeHolder	getAttributes() Get associated AttributeHolder.
int	getLocalWindowSize()
int	getPeerWindowSize()
int	getPriority()
int	getSlot()
HttpRequestPacket	getSpdyRequest()
HttpResponsePacket	getSpdyResponse()
static SpdyStream	getSpdyStream(HttpHeader httpHeader)
int	getStreamId()
int	getUnflushedWritesCount()
boolean	isLocallyInitiatedStream()
boolean	isOpen() Is Closeable open and ready.
boolean	isUnidirectional()
void	notifyCanWrite(WriteHandler writeHandler) Instructs the OutputSink to invoke the provided WriteHandler when it is possible to write more bytes (or characters).
void	notifyCanWrite(WriteHandler handler, int length) Deprecated.
boolean	removeCloseListener(CloseListener closeListener) Remove the CloseListener.
PushResource	removePushResource(String url)
GrizzlyFuture<Closeable>	terminate() Closes this stream and releases any system resources associated with it.
void	terminateSilently() Closes this stream and releases any system resources associated with it.
void	terminateWithReason(IOException cause) Closes the Closeable and provides the reason description.

Methods inherited from class java.lang.Object

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

Field Detail

SPDY_STREAM_ATTRIBUTE

public static final String SPDY_STREAM_ATTRIBUTE

Constructor Detail

SpdyStream

protected SpdyStream(SpdySession spdySession,
                     HttpRequestPacket spdyRequest,
                     int streamId,
                     int associatedToStreamId,
                     int priority,
                     int slot,
                     boolean isUnidirectional)

Method Detail

getSpdyStream

public static SpdyStream getSpdyStream(HttpHeader httpHeader)

getPeerWindowSize

public int getPeerWindowSize()

getLocalWindowSize

public int getLocalWindowSize()

getUnflushedWritesCount

public int getUnflushedWritesCount()

Returns:

the number of writes (not bytes), that haven't reached network layer

getSpdyRequest

public HttpRequestPacket getSpdyRequest()

getSpdyResponse

public HttpResponsePacket getSpdyResponse()

addPushResource

public PushResource addPushResource(String url,
                                    PushResource pushResource)

removePushResource

public PushResource removePushResource(String url)

getStreamId

public int getStreamId()

getAssociatedToStreamId

public int getAssociatedToStreamId()

getPriority

public int getPriority()

getSlot

public int getSlot()

isUnidirectional

public boolean isUnidirectional()

isLocallyInitiatedStream

public boolean isLocallyInitiatedStream()

isOpen

public boolean isOpen()

Description copied from interface: Closeable

Is Closeable open and ready. Returns true, if the Closeable is open and ready, or false otherwise.

Specified by:

isOpen in interface Closeable

Returns:

true, if Closeable is open and ready, or false otherwise.

assertOpen

public void assertOpen()
                throws IOException

Description copied from interface: Closeable

Checks if this Closeable is open and ready to be used. If this Closeable is closed - this method throws IOException giving the reason why this Closeable was closed.

Specified by:

assertOpen in interface Closeable

Throws:

IOException

getAttributes

public AttributeHolder getAttributes()

Description copied from interface: AttributeStorage

Get associated AttributeHolder. Implementation may return null if AttributeHolder wasn't initialized yet.

Specified by:

getAttributes in interface AttributeStorage

Returns:

associated AttributeHolder. Implementation may return null if AttributeHolder wasn't initialized yet.

canWrite

@Deprecated
public boolean canWrite(int length)

Deprecated.

Specified by:

canWrite in interface OutputSink

Parameters:

length - specifies the number of bytes (or characters) that require writing

Returns:

true if a write to this OutputSink will succeed, otherwise returns false.

canWrite

public boolean canWrite()

Specified by:

canWrite in interface OutputSink

Returns:

true if a write to this OutputSink will succeed, otherwise returns false.

notifyCanWrite

@Deprecated
public void notifyCanWrite(WriteHandler handler,
                                       int length)

Deprecated.

Description copied from interface: OutputSink

Instructs the OutputSink to invoke the provided WriteHandler when it is possible to write length bytes (or characters). Note that once the WriteHandler has been notified, it will not be considered for notification again at a later point in time.

Specified by:

notifyCanWrite in interface OutputSink

Parameters:

handler - the WriteHandler that should be notified when it's possible to write length bytes.

length - the number of bytes or characters that require writing.

notifyCanWrite

public void notifyCanWrite(WriteHandler writeHandler)

Description copied from interface: OutputSink

Instructs the OutputSink to invoke the provided WriteHandler when it is possible to write more bytes (or characters). Note that once the WriteHandler has been notified, it will not be considered for notification again at a later point in time.

Specified by:

notifyCanWrite in interface OutputSink

Parameters:

writeHandler - the WriteHandler that should be notified when it's possible to write more data.

terminate

public GrizzlyFuture<Closeable> terminate()

Description copied from interface: Closeable

Closes this stream and releases any system resources associated with it. If the stream is already closed then invoking this method has no effect.

Specified by:

terminate in interface Closeable

Returns:

Future, which could be checked in case, if close operation will be run asynchronously

terminateSilently

public void terminateSilently()

Description copied from interface: Closeable

Closes this stream and releases any system resources associated with it. If the stream is already closed then invoking this method has no effect. Use this method, when no completion notification is needed.

Specified by:

terminateSilently in interface Closeable

terminateWithReason

public void terminateWithReason(IOException cause)

Description copied from interface: Closeable

Closes the Closeable and provides the reason description. This method is similar to Closeable.terminateSilently(), but additionally provides the reason why the Closeable will be closed.

Specified by:

terminateWithReason in interface Closeable

close

public GrizzlyFuture<Closeable> close()

Description copied from interface: Closeable

Gracefully (if supported by the implementation) closes this stream and releases any system resources associated with it. If the stream is already closed then invoking this method has no effect.

Specified by:

close in interface Closeable

Returns:

Future, which could be checked in case, if close operation will be run asynchronously

closeSilently

public void closeSilently()

Description copied from interface: Closeable

Gracefully (if supported by the implementation) closes this stream and releases any system resources associated with it. If the stream is already closed then invoking this method has no effect. Use this method, when no completion notification is needed.

Specified by:

closeSilently in interface Closeable

close

public void close(CompletionHandler<Closeable> completionHandler)

Deprecated. please use close() with the following GrizzlyFuture.addCompletionHandler(org.glassfish.grizzly.CompletionHandler) call

Gracefully closes this stream and releases any system resources associated with it. This operation waits for all pending output data to be flushed before closing the stream. If the stream is already closed then invoking this method has no effect.

Specified by:

close in interface Closeable

Parameters:

completionHandler - CompletionHandler to be called, when the stream is closed

closeWithReason

public void closeWithReason(IOException cause)

Description copied from interface: Closeable

Gracefully closes the Closeable and provides the reason description. This method is similar to Closeable.closeSilently(), but additionally provides the reason why the Closeable will be closed.

Specified by:

closeWithReason in interface Closeable

addCloseListener

public void addCloseListener(CloseListener closeListener)

Description copied from interface: Closeable

Add the CloseListener, which will be notified once the stream will be closed.

Specified by:

addCloseListener in interface Closeable

Parameters:

closeListener - CloseListener.

removeCloseListener

public boolean removeCloseListener(CloseListener closeListener)

Description copied from interface: Closeable

Remove the CloseListener.

Specified by:

removeCloseListener in interface Closeable

Parameters:

closeListener - CloseListener.

Returns:

true if the listener was successfully removed, or false otherwise.

closeFuture

public GrizzlyFuture<CloseReason> closeFuture()

Specified by:

closeFuture in interface Closeable

Returns:

the Future, that will be notified once this Closeable is closed