okhttp3.internal.http2

Class Http2Stream.FramingSource

java.lang.Object

okhttp3.internal.http2.Http2Stream.FramingSource

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, okio.Source

Enclosing class:

Http2Stream

private final class Http2Stream.FramingSource
extends java.lang.Object
implements okio.Source

A source that reads the incoming data frames of a stream. Although this class uses synchronization to safely receive incoming data frames, it is not intended for use by multiple readers.

Field Summary

Fields

Modifier and Type	Field and Description
(package private) boolean	closed True if the caller has closed this stream.
(package private) boolean	finished True if either side has cleanly shut down this stream.
private long	maxByteCount Maximum number of bytes to buffer before reporting a flow control error.
private okio.Buffer	readBuffer Buffer with readable data.
private okio.Buffer	receiveBuffer Buffer to receive data from the network into.

Constructor Summary

Constructors

Constructor and Description
FramingSource(long maxByteCount)

Method Summary

Modifier and Type	Method and Description
private void	checkNotClosed()
void	close()
long	read(okio.Buffer sink, long byteCount)
(package private) void	receive(okio.BufferedSource in, long byteCount)
okio.Timeout	timeout()
private void	waitUntilReadable() Returns once the source is either readable or finished.

Methods inherited from class java.lang.Object

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

Field Detail

receiveBuffer

private final okio.Buffer receiveBuffer

Buffer to receive data from the network into. Only accessed by the reader thread.

readBuffer

private final okio.Buffer readBuffer

Buffer with readable data. Guarded by Http2Stream.this.

maxByteCount

private final long maxByteCount

Maximum number of bytes to buffer before reporting a flow control error.

closed

boolean closed

True if the caller has closed this stream.

finished

boolean finished

True if either side has cleanly shut down this stream. We will receive no more bytes beyond those already in the buffer.

Constructor Detail

FramingSource

FramingSource(long maxByteCount)

Method Detail

read

public long read(okio.Buffer sink,
                 long byteCount)
          throws java.io.IOException

Specified by:

read in interface okio.Source

Throws:

java.io.IOException

waitUntilReadable

private void waitUntilReadable()
                        throws java.io.IOException

Returns once the source is either readable or finished.

Throws:

java.io.IOException

receive

void receive(okio.BufferedSource in,
             long byteCount)
      throws java.io.IOException

Throws:

java.io.IOException

timeout

public okio.Timeout timeout()

Specified by:

timeout in interface okio.Source

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface okio.Source

Throws:

java.io.IOException

checkNotClosed

private void checkNotClosed()
                     throws java.io.IOException

Throws:

java.io.IOException