Class AbstractStream

java.lang.Object

org.eclipse.jetty.quic.common.AbstractStream

All Implemented Interfaces:

CyclicTimeouts.Expirable, Stream

Direct Known Subclasses:

QuicheStream

public abstract class AbstractStream
extends Object
implements Stream, CyclicTimeouts.Expirable

Nested Class Summary

Nested classes/interfaces inherited from interface org.eclipse.jetty.quic.api.Stream

Stream.Listener

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractStream(long streamId, boolean local)

Method Summary

Modifier and Type	Method	Description
long	getExpireNanoTime()	Returns the expiration time in nanoseconds.
long	getId()	Returns the stream id.
long	getIdleTimeout()
Stream.Listener	getListener()
boolean	isBidirectional()	Returns whether the stream is bidirectional.
boolean	isLocal()	Returns whether the stream has been created locally or remotely.
protected void	notIdle()
void	setIdleTimeout(long idleTimeout)
void	setListener(Stream.Listener listener)
String	toString()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.eclipse.jetty.quic.api.Stream

data, dataBlocked, demand, disconnect, getSession, isClosed, isLocallyClosed, isRemotelyClosed, maxData, read, reset, stopSending

Constructor Details

AbstractStream

protected AbstractStream(long streamId,
 boolean local)

Method Details

getId

public long getId()

Description copied from interface: Stream

Returns the stream id.

Specified by:

getId in interface Stream

Returns:

the stream id

isBidirectional

public boolean isBidirectional()

Description copied from interface: Stream

Returns whether the stream is bidirectional.

Specified by:

isBidirectional in interface Stream

Returns:

whether the stream is bidirectional

isLocal

public boolean isLocal()

Description copied from interface: Stream

Returns whether the stream has been created locally or remotely.

Specified by:

isLocal in interface Stream

Returns:

whether the stream is local or remote

getListener

public Stream.Listener getListener()

setListener

public void setListener(Stream.Listener listener)

getIdleTimeout

public long getIdleTimeout()

Specified by:

getIdleTimeout in interface Stream

setIdleTimeout

public void setIdleTimeout(long idleTimeout)

Specified by:

setIdleTimeout in interface Stream

notIdle

protected void notIdle()

getExpireNanoTime

public long getExpireNanoTime()

Description copied from interface: CyclicTimeouts.Expirable

Returns the expiration time in nanoseconds.

The value to return must be calculated taking into account the current nanoTime, for example:

expireNanoTime = NanoTime.now() + timeoutNanos

Returning Long.MAX_VALUE indicates that this entity does not expire.

Specified by:

getExpireNanoTime in interface CyclicTimeouts.Expirable

Returns:

the expiration time in nanoseconds, or Long.MAX_VALUE if this entity does not expire

toString

public String toString()

Overrides:

toString in class Object