Searched refs:BufferedSink (Results 1 - 25 of 48) sorted by relevance

12

/external/okhttp/okio/okio/src/main/java/okio/
H A DBufferedSink.java26 public interface BufferedSink extends Sink { interface in inherits:Sink
30 BufferedSink write(ByteString byteString) throws IOException;
36 BufferedSink write(byte[] source) throws IOException;
42 BufferedSink write(byte[] source, int offset, int byteCount) throws IOException;
51 BufferedSink write(Source source, long byteCount) throws IOException;
54 BufferedSink writeUtf8(String string) throws IOException;
60 BufferedSink writeUtf8(String string, int beginIndex, int endIndex) throws IOException;
63 BufferedSink writeUtf8CodePoint(int codePoint) throws IOException;
66 BufferedSink writeString(String string, Charset charset) throws IOException;
72 BufferedSink writeStrin
[all...]
H A DRealBufferedSink.java23 final class RealBufferedSink implements BufferedSink {
49 @Override public BufferedSink write(ByteString byteString) throws IOException {
55 @Override public BufferedSink writeUtf8(String string) throws IOException {
61 @Override public BufferedSink writeUtf8(String string, int beginIndex, int endIndex)
68 @Override public BufferedSink writeUtf8CodePoint(int codePoint) throws IOException {
74 @Override public BufferedSink writeString(String string, Charset charset) throws IOException {
80 @Override public BufferedSink writeString(String string, int beginIndex, int endIndex,
87 @Override public BufferedSink write(byte[] source) throws IOException {
93 @Override public BufferedSink write(byte[] source, int offset, int byteCount) throws IOException {
109 @Override public BufferedSink writ
[all...]
H A DDeflaterSink.java38 private final BufferedSink sink;
51 DeflaterSink(BufferedSink sink, Deflater deflater) {
H A DGzipSink.java40 private final BufferedSink sink;
/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/spdy/
H A DVariant.java19 import okio.BufferedSink;
36 FrameWriter newWriter(BufferedSink sink, boolean client);
/external/okhttp/okhttp-ws/src/main/java/com/squareup/okhttp/ws/
H A DWebSocket.java20 import okio.BufferedSink;
35 * You must call {@link BufferedSink#close() close()} to complete the message. Calls to
36 * {@link BufferedSink#flush() flush()} write a frame fragment. The message may be empty.
40 BufferedSink newMessageSink(WebSocket.PayloadType type);
H A DWebSocketCall.java37 import okio.BufferedSink;
176 BufferedSink sink = Internal.instance.connectionRawSink(connection);
198 BufferedSink sink, Random random, WebSocketListener listener) {
211 private ConnectionWebSocket(Connection connection, BufferedSource source, BufferedSink sink,
/external/okhttp/okio/okio/src/test/java/okio/
H A DRealBufferedSinkTest.java28 * BufferedSink behavior use BufferedSinkTest.
45 BufferedSink bufferedSink = new RealBufferedSink(sink);
55 BufferedSink bufferedSink = new RealBufferedSink(sink);
63 BufferedSink bufferedSink = new RealBufferedSink(sink);
73 BufferedSink bufferedSink = new RealBufferedSink(sink);
81 BufferedSink bufferedSink = new RealBufferedSink(sink);
88 BufferedSink bufferedSink = new RealBufferedSink(sink);
96 BufferedSink bufferedSink = new RealBufferedSink(sink);
103 BufferedSink bufferedSink = new RealBufferedSink(sink);
111 BufferedSink bufferedSin
[all...]
H A DOkioTest.java38 BufferedSink sink = Okio.buffer(Okio.sink(file));
52 BufferedSink sink = Okio.buffer(Okio.appendingSink(file));
72 // BufferedSink sink = Okio.buffer(Okio.sink(path));
H A DBufferedSinkTest.java39 BufferedSink create(Buffer data);
48 @Override public BufferedSink create(Buffer data) {
58 @Override public BufferedSink create(Buffer data) {
75 private BufferedSink sink;
/external/okhttp/okhttp-apache/src/main/java/com/squareup/okhttp/apache/
H A DHttpEntityBody.java6 import okio.BufferedSink;
38 @Override public void writeTo(BufferedSink sink) throws IOException {
/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/
H A DRequestBody.java22 import okio.BufferedSink;
40 public abstract void writeTo(BufferedSink sink) throws IOException;
70 @Override public void writeTo(BufferedSink sink) throws IOException {
95 @Override public void writeTo(BufferedSink sink) throws IOException {
114 @Override public void writeTo(BufferedSink sink) throws IOException {
H A DMultipartBuilder.java24 import okio.BufferedSink;
229 private long writeOrCountBytes(BufferedSink sink, boolean countBytes) throws IOException {
296 @Override public void writeTo(BufferedSink sink) throws IOException {
/external/okhttp/samples/guide/src/main/java/com/squareup/okhttp/recipes/
H A DPostStreaming.java24 import okio.BufferedSink;
38 @Override public void writeTo(BufferedSink sink) throws IOException {
H A DRequestBodyCompression.java28 import okio.BufferedSink;
92 @Override public void writeTo(BufferedSink sink) throws IOException {
93 BufferedSink gzipSink = Okio.buffer(new GzipSink(sink));
/external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/
H A DSocksProxy.java35 import okio.BufferedSink;
101 BufferedSink fromSink = Okio.buffer(Okio.sink(from));
112 private void hello(BufferedSource fromSource, BufferedSink fromSink) throws IOException {
141 BufferedSink fromSink) throws IOException {
189 BufferedSink toSink = Okio.buffer(Okio.sink(toSocket));
200 final BufferedSource source, final BufferedSink sink) {
H A DMultipartBuilderTest.java20 import okio.BufferedSink;
193 @Override public void writeTo(BufferedSink sink) throws IOException {
/external/okhttp/okhttp-ws/src/main/java/com/squareup/okhttp/internal/ws/
H A DRealWebSocket.java26 import okio.BufferedSink;
46 public RealWebSocket(boolean isClient, BufferedSource source, BufferedSink sink, Random random,
103 @Override public BufferedSink newMessageSink(PayloadType type) {
H A DWebSocketWriter.java21 import okio.BufferedSink;
53 private final BufferedSink sink;
64 public WebSocketWriter(boolean isClient, BufferedSink sink, Random random) {
158 public BufferedSink newMessageSink(PayloadType type) {
/external/okhttp/okhttp-ws-tests/src/test/java/com/squareup/okhttp/internal/ws/
H A DWebSocketWriterTest.java23 import okio.BufferedSink;
59 BufferedSink sink = serverWriter.newMessageSink(TEXT);
72 BufferedSink sink = serverWriter.newMessageSink(TEXT);
83 BufferedSink sink = clientWriter.newMessageSink(TEXT);
132 BufferedSink sink = serverWriter.newMessageSink(BINARY);
157 BufferedSink sink = clientWriter.newMessageSink(BINARY);
H A DRealWebSocketTest.java27 import okio.BufferedSink;
95 BufferedSink sink = client.newMessageSink(TEXT);
104 BufferedSink sink = client.newMessageSink(TEXT);
194 BufferedSink sink = client.newMessageSink(TEXT);
/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/
H A DInternal.java33 import okio.BufferedSink;
93 public abstract BufferedSink connectionRawSink(Connection connection);
/external/okhttp/mockwebserver/src/main/java/com/squareup/okhttp/internal/spdy/
H A DSpdyServer.java34 import okio.BufferedSink;
128 BufferedSink out = Okio.buffer(stream.getSink());
140 BufferedSink out = Okio.buffer(stream.getSink());
157 BufferedSink out = Okio.buffer(stream.getSink());
/external/okhttp/okhttp-ws-tests/src/test/java/com/squareup/okhttp/ws/
H A DWebSocketCallTest.java30 import okio.BufferedSink;
85 BufferedSink sink = webSocket.newMessageSink(TEXT);
97 BufferedSink sink = webSocket.newMessageSink(TEXT);
/external/okhttp/mockwebserver/src/main/java/com/squareup/okhttp/mockwebserver/
H A DMockWebServer.java73 import okio.BufferedSink;
445 BufferedSink sink = Okio.buffer(Okio.sink(socket));
469 BufferedSink sink = Okio.buffer(Okio.sink(raw));
483 private boolean processOneRequest(Socket socket, BufferedSource source, BufferedSink sink)
552 private RecordedRequest readRequest(Socket socket, BufferedSource source, BufferedSink sink,
632 private void handleWebSocketUpgrade(Socket socket, BufferedSource source, BufferedSink sink,
696 private void writeHttpResponse(Socket socket, BufferedSink sink, MockResponse response)
734 BufferedSink sink, long byteCount) throws IOException {
900 BufferedSink sink = Okio.buffer(stream.getSink());

Completed in 337 milliseconds

12