okhttp3.internal.http2

Class Http2Stream.FramingSink

java.lang.Object

okhttp3.internal.http2.Http2Stream.FramingSink

All Implemented Interfaces:

java.io.Closeable, java.io.Flushable, java.lang.AutoCloseable, okio.Sink

Enclosing class:

Http2Stream

final class Http2Stream.FramingSink
extends java.lang.Object
implements okio.Sink

A sink that writes outgoing data frames of a stream. This class is not thread safe.

Field Summary

Fields

Modifier and Type	Field and Description
(package private) boolean	closed
private static long	EMIT_BUFFER_SIZE
(package private) boolean	finished True if either side has cleanly shut down this stream.
private okio.Buffer	sendBuffer Buffer of outgoing data.

Constructor Summary

Constructors

Constructor and Description
FramingSink()

Method Summary

Modifier and Type	Method and Description
void	close()
private void	emitFrame(boolean outFinished) Emit a single data frame to the connection.
void	flush()
okio.Timeout	timeout()
void	write(okio.Buffer source, long byteCount)

Methods inherited from class java.lang.Object

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

Field Detail

EMIT_BUFFER_SIZE

private static final long EMIT_BUFFER_SIZE

See Also:

Constant Field Values

sendBuffer

private final okio.Buffer sendBuffer

Buffer of outgoing data. This batches writes of small writes into this sink as larges frames written to the outgoing connection. Batching saves the (small) framing overhead.

closed

boolean closed

finished

boolean finished

True if either side has cleanly shut down this stream. We shall send no more bytes.

Constructor Detail

FramingSink

FramingSink()

Method Detail

write

public void write(okio.Buffer source,
                  long byteCount)
           throws java.io.IOException

Specified by:

write in interface okio.Sink

Throws:

java.io.IOException

emitFrame

private void emitFrame(boolean outFinished)
                throws java.io.IOException

Emit a single data frame to the connection. The frame's size be limited by this stream's write window. This method will block until the write window is nonempty.

Throws:

java.io.IOException

flush

public void flush()
           throws java.io.IOException

Specified by:

flush in interface java.io.Flushable

Specified by:

flush in interface okio.Sink

Throws:

java.io.IOException

timeout

public okio.Timeout timeout()

Specified by:

timeout in interface okio.Sink

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.Sink

Throws:

java.io.IOException