com.squareup.okhttp.internal.ws

Class WebSocketWriter

java.lang.Object

com.squareup.okhttp.internal.ws.WebSocketWriter

public final class WebSocketWriter
extends Object

An RFC 6455-compatible WebSocket frame writer.

This class is partially thread safe. Only a single "main" thread should be sending messages via calls to newMessageSink(int), writePing(okio.Buffer), or writeClose(int, java.lang.String). Other threads may call writePing(okio.Buffer), writePong(okio.Buffer), or writeClose(int, java.lang.String) which will interleave on the wire with frames from the "main" sending thread.

Constructor Summary

Constructors

Constructor and Description
WebSocketWriter(boolean isClient, okio.BufferedSink sink, Random random)

Method Summary

Modifier and Type	Method and Description
okio.Sink	newMessageSink(int formatOpcode) Stream a message payload as a series of frames.
void	writeClose(int code, String reason) Send a close frame with optional code and reason.
void	writePing(okio.Buffer payload) Send a ping with the supplied payload.
void	writePong(okio.Buffer payload) Send a pong with the supplied payload.

Methods inherited from class java.lang.Object

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

Constructor Detail

WebSocketWriter

public WebSocketWriter(boolean isClient,
                       okio.BufferedSink sink,
                       Random random)

Method Detail

writePing

public void writePing(okio.Buffer payload)
               throws IOException

Send a ping with the supplied payload. Payload may be null

Throws:

IOException

writePong

public void writePong(okio.Buffer payload)
               throws IOException

Send a pong with the supplied payload. Payload may be null

Throws:

IOException

writeClose

public void writeClose(int code,
                       String reason)
                throws IOException

Send a close frame with optional code and reason.

Parameters:

code - Status code as defined by Section 7.4 of RFC 6455 or 0.

reason - Reason for shutting down or null.

Throws:

IOException

newMessageSink

public okio.Sink newMessageSink(int formatOpcode)

Stream a message payload as a series of frames. This allows control frames to be interleaved between parts of the message.