APIdia Launch Partner
Top Description Fields Constructors Methods
jdk.internal.net.http.quic.streams

public final Class QuicBidiStreamImpl

extends AbstractQuicStream
implements QuicBidiStream
Class Inheritance
All Implemented Interfaces
jdk.internal.net.http.quic.streams.QuicBidiStream, jdk.internal.net.http.quic.streams.QuicSenderStream, jdk.internal.net.http.quic.streams.QuicStream, jdk.internal.net.http.quic.streams.QuicReceiverStream
Imports
java.io.IOException, jdk.internal.net.http.common.SequentialScheduler, jdk.internal.net.http.quic.QuicConnectionImpl
An implementation of a bidirectional stream. A bidirectional stream implements both QuicSenderStream and QuicReceiverStream.

Field Summary

Modifier and TypeField and Description
private final QuicReceiverStreamImpl
receiverPart

private final QuicSenderStreamImpl
senderPart

Constructor Summary

AccessConstructor and Description
pack-priv
QuicBidiStreamImpl(QuicConnectionImpl connection, long streamId)

private
QuicBidiStreamImpl(QuicConnectionImpl connection, long streamId, QuicSenderStreamImpl sender, QuicReceiverStreamImpl receiver)

Method Summary

Modifier and TypeMethod and Description
public QuicStreamReader
connectReader(SequentialScheduler scheduler)

Implements jdk.internal.net.http.quic.streams.QuicReceiverStream.connectReader.

Connects an unstarted reader to the receiver end of this stream.

public QuicStreamWriter
connectWriter(SequentialScheduler scheduler)

Implements jdk.internal.net.http.quic.streams.QuicSenderStream.connectWriter.

Connects a writer to the sending end of this stream.

public long
dataReceived()

Implements jdk.internal.net.http.quic.streams.QuicReceiverStream.dataReceived.

Returns the amount of data that has been received so far.

public long
dataSent()

Implements jdk.internal.net.http.quic.streams.QuicSenderStream.dataSent.

Returns the amount of data that has been sent.

public void
disconnectReader(QuicStreamReader reader)

Implements jdk.internal.net.http.quic.streams.QuicReceiverStream.disconnectReader.

Disconnect the reader, so that a new reader can be connected.

public void
disconnectWriter(QuicStreamWriter writer)

Implements jdk.internal.net.http.quic.streams.QuicSenderStream.disconnectWriter.

Disconnect the writer, so that a new writer can be connected.

public boolean
isDone()

Implements abstract jdk.internal.net.http.quic.streams.AbstractQuicStream.isDone.

Returns true if this stream isn't expecting anything from the peer and can be removed from the streams map.

public boolean
isStopSendingRequested()

Overrides default jdk.internal.net.http.quic.streams.QuicReceiverStream.isStopSendingRequested.

public long
maxStreamData()

Implements jdk.internal.net.http.quic.streams.QuicReceiverStream.maxStreamData.

Returns the maximum amount of data that can be received on this stream.

public long
rcvErrorCode()

Implements jdk.internal.net.http.quic.streams.QuicReceiverStream.rcvErrorCode.

Returns the error code for this stream, or -1.

public QuicReceiverStreamImpl

Returns:

the receiver part implementation of this bidirectional stream
receiverPart()

Returns the receiver part implementation of this bidirectional stream.

public QuicReceiverStream.ReceivingStreamState
receivingState()

Implements jdk.internal.net.http.quic.streams.QuicReceiverStream.receivingState.

Returns the receiving state of the stream.

public void
requestStopSending(long errorCode)

Implements jdk.internal.net.http.quic.streams.QuicReceiverStream.requestStopSending.

Cancels the reading side of this stream by sending a STOP_SENDING frame.

public void
reset(long errorCode)

Implements jdk.internal.net.http.quic.streams.QuicSenderStream.reset.

Abruptly closes the writing side of a stream by sending a RESET_STREAM frame.

public QuicSenderStreamImpl

Returns:

the sender part implementation of this bidirectional stream
senderPart()

Returns the sender part implementation of this bidirectional stream.

public QuicSenderStream.SendingStreamState
sendingState()

Implements jdk.internal.net.http.quic.streams.QuicSenderStream.sendingState.

Returns the sending state of the stream.

public long
sndErrorCode()

Implements jdk.internal.net.http.quic.streams.QuicSenderStream.sndErrorCode.

Returns the error code for this stream, or -1.

public boolean
stopSendingReceived()

Implements jdk.internal.net.http.quic.streams.QuicSenderStream.stopSendingReceived.

Returns true if STOP_SENDING was received.

Inherited from jdk.internal.net.http.quic.streams.AbstractQuicStream:
connectionisBidirectionalisClientInitiatedisLocalInitiatedisRemoteInitiatedisServerInitiatedmodestreamIdtype

Field Detail

receiverPartback to summary
private final QuicReceiverStreamImpl receiverPart
senderPartback to summary
private final QuicSenderStreamImpl senderPart

Constructor Detail

QuicBidiStreamImplback to summary
pack-priv QuicBidiStreamImpl(QuicConnectionImpl connection, long streamId)
QuicBidiStreamImplback to summary
private QuicBidiStreamImpl(QuicConnectionImpl connection, long streamId, QuicSenderStreamImpl sender, QuicReceiverStreamImpl receiver)

Method Detail

connectReaderback to summary
public QuicStreamReader connectReader(SequentialScheduler scheduler)

Implements jdk.internal.net.http.quic.streams.QuicReceiverStream.connectReader.

Doc from jdk.internal.net.http.quic.streams.QuicReceiverStream.connectReader.

Connects an unstarted reader to the receiver end of this stream.

Annotations
@Override
connectWriterback to summary
public QuicStreamWriter connectWriter(SequentialScheduler scheduler)

Implements jdk.internal.net.http.quic.streams.QuicSenderStream.connectWriter.

Doc from jdk.internal.net.http.quic.streams.QuicSenderStream.connectWriter.

Connects a writer to the sending end of this stream.

Annotations
@Override
dataReceivedback to summary
public long dataReceived()

Implements jdk.internal.net.http.quic.streams.QuicReceiverStream.dataReceived.

Doc from jdk.internal.net.http.quic.streams.QuicReceiverStream.dataReceived.

Returns the amount of data that has been received so far.

Annotations
@Override
dataSentback to summary
public long dataSent()

Implements jdk.internal.net.http.quic.streams.QuicSenderStream.dataSent.

Doc from jdk.internal.net.http.quic.streams.QuicSenderStream.dataSent.

Returns the amount of data that has been sent.

Annotations
@Override
disconnectReaderback to summary
public void disconnectReader(QuicStreamReader reader)

Implements jdk.internal.net.http.quic.streams.QuicReceiverStream.disconnectReader.

Doc from jdk.internal.net.http.quic.streams.QuicReceiverStream.disconnectReader.

Disconnect the reader, so that a new reader can be connected.

Annotations
@Override
disconnectWriterback to summary
public void disconnectWriter(QuicStreamWriter writer)

Implements jdk.internal.net.http.quic.streams.QuicSenderStream.disconnectWriter.

Doc from jdk.internal.net.http.quic.streams.QuicSenderStream.disconnectWriter.

Disconnect the writer, so that a new writer can be connected.

Annotations
@Override
isDoneback to summary
public boolean isDone()

Implements abstract jdk.internal.net.http.quic.streams.AbstractQuicStream.isDone.

Doc from jdk.internal.net.http.quic.streams.AbstractQuicStream.isDone.

Returns true if this stream isn't expecting anything from the peer and can be removed from the streams map.

Annotations
@Override
isStopSendingRequestedback to summary
public boolean isStopSendingRequested()

Overrides default jdk.internal.net.http.quic.streams.QuicReceiverStream.isStopSendingRequested.

Annotations
@Override
maxStreamDataback to summary
public long maxStreamData()

Implements jdk.internal.net.http.quic.streams.QuicReceiverStream.maxStreamData.

Doc from jdk.internal.net.http.quic.streams.QuicReceiverStream.maxStreamData.

Returns the maximum amount of data that can be received on this stream.

Annotations
@Override
rcvErrorCodeback to summary
public long rcvErrorCode()

Implements jdk.internal.net.http.quic.streams.QuicReceiverStream.rcvErrorCode.

Doc from jdk.internal.net.http.quic.streams.QuicReceiverStream.rcvErrorCode.

Returns the error code for this stream, or -1.

Annotations
@Override
receiverPartback to summary
public QuicReceiverStreamImpl receiverPart()

Returns the receiver part implementation of this bidirectional stream.

Returns:QuicReceiverStreamImpl

the receiver part implementation of this bidirectional stream

receivingStateback to summary
public QuicReceiverStream.ReceivingStreamState receivingState()

Implements jdk.internal.net.http.quic.streams.QuicReceiverStream.receivingState.

Doc from jdk.internal.net.http.quic.streams.QuicReceiverStream.receivingState.

Returns the receiving state of the stream.

Annotations
@Override
requestStopSendingback to summary
public void requestStopSending(long errorCode)

Implements jdk.internal.net.http.quic.streams.QuicReceiverStream.requestStopSending.

Doc from jdk.internal.net.http.quic.streams.QuicReceiverStream.requestStopSending.

Cancels the reading side of this stream by sending a STOP_SENDING frame.

Annotations
@Override
resetback to summary
public void reset(long errorCode) throws IOException

Implements jdk.internal.net.http.quic.streams.QuicSenderStream.reset.

Doc from jdk.internal.net.http.quic.streams.QuicSenderStream.reset.

Abruptly closes the writing side of a stream by sending a RESET_STREAM frame.

Annotations
@Override
senderPartback to summary
public QuicSenderStreamImpl senderPart()

Returns the sender part implementation of this bidirectional stream.

Returns:QuicSenderStreamImpl

the sender part implementation of this bidirectional stream

sendingStateback to summary
public QuicSenderStream.SendingStreamState sendingState()

Implements jdk.internal.net.http.quic.streams.QuicSenderStream.sendingState.

Doc from jdk.internal.net.http.quic.streams.QuicSenderStream.sendingState.

Returns the sending state of the stream.

Annotations
@Override
sndErrorCodeback to summary
public long sndErrorCode()

Implements jdk.internal.net.http.quic.streams.QuicSenderStream.sndErrorCode.

Doc from jdk.internal.net.http.quic.streams.QuicSenderStream.sndErrorCode.

Returns the error code for this stream, or -1.

Annotations
@Override
stopSendingReceivedback to summary
public boolean stopSendingReceived()

Implements jdk.internal.net.http.quic.streams.QuicSenderStream.stopSendingReceived.

Doc from jdk.internal.net.http.quic.streams.QuicSenderStream.stopSendingReceived.

Returns true if STOP_SENDING was received.

Annotations
@Override