final class WebSocketWriter
extends java.lang.Object
This class is not thread safe.
Modifier and Type | Class and Description |
---|---|
(package private) class |
WebSocketWriter.FrameSink |
Modifier and Type | Field and Description |
---|---|
(package private) boolean |
activeWriter |
(package private) okio.Buffer |
buffer |
(package private) WebSocketWriter.FrameSink |
frameSink |
(package private) boolean |
isClient |
private okio.Buffer.UnsafeCursor |
maskCursor |
private byte[] |
maskKey |
(package private) java.util.Random |
random |
(package private) okio.BufferedSink |
sink |
(package private) okio.Buffer |
sinkBuffer
The
Buffer of sink . |
(package private) boolean |
writerClosed |
Constructor and Description |
---|
WebSocketWriter(boolean isClient,
okio.BufferedSink sink,
java.util.Random random) |
Modifier and Type | Method and Description |
---|---|
(package private) okio.Sink |
newMessageSink(int formatOpcode,
long contentLength)
Stream a message payload as a series of frames.
|
(package private) void |
writeClose(int code,
okio.ByteString reason)
Send a close frame with optional code and reason.
|
private void |
writeControlFrame(int opcode,
okio.ByteString payload) |
(package private) void |
writeMessageFrame(int formatOpcode,
long byteCount,
boolean isFirstFrame,
boolean isFinal) |
(package private) void |
writePing(okio.ByteString payload)
Send a ping with the supplied
payload . |
(package private) void |
writePong(okio.ByteString payload)
Send a pong with the supplied
payload . |
final boolean isClient
final java.util.Random random
final okio.BufferedSink sink
final okio.Buffer sinkBuffer
boolean writerClosed
final okio.Buffer buffer
final WebSocketWriter.FrameSink frameSink
boolean activeWriter
private final byte[] maskKey
private final okio.Buffer.UnsafeCursor maskCursor
WebSocketWriter(boolean isClient, okio.BufferedSink sink, java.util.Random random)
void writePing(okio.ByteString payload) throws java.io.IOException
payload
.java.io.IOException
void writePong(okio.ByteString payload) throws java.io.IOException
payload
.java.io.IOException
void writeClose(int code, okio.ByteString reason) throws java.io.IOException
code
- Status code as defined by Section 7.4 of RFC 6455 or 0
.reason
- Reason for shutting down or null
.java.io.IOException
private void writeControlFrame(int opcode, okio.ByteString payload) throws java.io.IOException
java.io.IOException
okio.Sink newMessageSink(int formatOpcode, long contentLength)
void writeMessageFrame(int formatOpcode, long byteCount, boolean isFirstFrame, boolean isFinal) throws java.io.IOException
java.io.IOException