| /external/okhttp/okio/src/test/java/okio/ |
| DeflaterSinkTest.java | 32 OkBuffer data = new OkBuffer();
35 OkBuffer sink = new OkBuffer();
39 OkBuffer inflated = inflate(sink);
45 OkBuffer data = new OkBuffer();
47 OkBuffer sink = new OkBuffer();
51 OkBuffer inflated = inflate(sink)
[all...] |
| InflaterSourceTest.java | 31 OkBuffer deflated = decodeBase64("eJxzz09RyEjNKVAoLdZRKE9VL0pVyMxTKMlIVchIzEspVshPU0jNS8/MS00tK"
33 OkBuffer inflated = inflate(deflated);
38 OkBuffer deflated = decodeBase64("eJxzz09RyEjNKVAoLdZRKE9VL0pVyMxTKMlIVchIzEspVshPU0jNS8/MS00tK"
48 OkBuffer deflated = decodeBase64("eJztwTEBAAAAwqCs61/CEL5AAQAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA"
66 OkBuffer inflated = inflate(deflated);
72 OkBuffer deflated = deflate(original);
73 OkBuffer inflated = inflate(deflated);
77 private OkBuffer decodeBase64(String s) {
78 return new OkBuffer().write(ByteString.decodeBase64(s));
81 private String readUtf8(OkBuffer buffer)
[all...] |
| OkBufferTest.java | 31 OkBuffer buffer = new OkBuffer();
48 OkBuffer buffer = new OkBuffer();
53 OkBuffer buffer = new OkBuffer();
59 OkBuffer buffer = new OkBuffer();
65 OkBuffer buffer = new OkBuffer();
[all...] |
| OkBufferReadUtf8LineTest.java | 20 return new OkBuffer().writeUtf8(s);
|
| GzipSourceTest.java | 31 OkBuffer gzipped = new OkBuffer();
43 OkBuffer gzipped = new OkBuffer();
52 OkBuffer gzipped = new OkBuffer();
62 OkBuffer gzipped = new OkBuffer();
72 OkBuffer gzipped = new OkBuffer();
[all...] |
| RealBufferedSourceReadUtf8LineTest.java | 23 final OkBuffer buffer = new OkBuffer().writeUtf8(s);
26 @Override public long read(OkBuffer sink, long byteCount) throws IOException {
|
| RealBufferedSinkTest.java | 29 OkBuffer sink = new OkBuffer();
39 OkBuffer sink = new OkBuffer();
49 OkBuffer sink = new OkBuffer();
59 OkBuffer sink = new OkBuffer();
66 OkBuffer sink = new OkBuffer();
[all...] |
| RealBufferedSourceTest.java | 30 OkBuffer source = new OkBuffer();
66 OkBuffer source = new OkBuffer();
77 OkBuffer source = new OkBuffer();
89 OkBuffer source = new OkBuffer();
100 OkBuffer source = new OkBuffer();
[all...] |
| OkioTest.java | 30 OkBuffer data = new OkBuffer();
49 OkBuffer sink = new OkBuffer();
70 source.read(new OkBuffer(), -1);
|
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/spdy/ |
| Spdy3Test.java | 21 import okio.OkBuffer;
32 sendDataFrame(new OkBuffer().write(new byte[0x1000000]));
56 OkBuffer frame = new OkBuffer();
86 private void sendDataFrame(OkBuffer source) throws IOException {
87 Spdy3.Writer writer = new Spdy3.Writer(new OkBuffer(), true);
92 new Spdy3.Writer(new OkBuffer(), true).windowUpdate(expectedStreamId, increment);
95 private OkBuffer sendGoAway(int lastGoodStreamId, ErrorCode errorCode, byte[] debugData)
97 OkBuffer out = new OkBuffer();
[all...] |
| Http20Draft09Test.java | 24 import okio.OkBuffer;
37 OkBuffer frame = new OkBuffer();
54 OkBuffer frame = new OkBuffer();
58 OkBuffer headerBytes = literalHeaders(sentHeaders);
87 OkBuffer frame = new OkBuffer();
92 OkBuffer headerBytes = literalHeaders(sentHeaders);
124 OkBuffer frame = new OkBuffer()
[all...] |
| HpackDraft05Test.java | 22 import okio.OkBuffer;
33 private final OkBuffer bytesIn = new OkBuffer();
35 private OkBuffer bytesOut = new OkBuffer();
69 OkBuffer out = new OkBuffer();
90 OkBuffer out = new OkBuffer();
141 OkBuffer out = new OkBuffer()
[all...] |
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/http/ |
| RetryableSink.java | 23 import okio.OkBuffer;
36 private final OkBuffer content = new OkBuffer();
55 @Override public void write(OkBuffer source, long byteCount) throws IOException {
|
| /external/okhttp/okio/src/main/java/okio/ |
| Sink.java | 31 * <p>Sinks are easy to test: just use an {@link OkBuffer} in your tests, and
52 void write(OkBuffer source, long byteCount) throws IOException;
|
| Source.java | 31 * <p>Sources are easy to test: just use an {@link OkBuffer} in your tests, and
68 long read(OkBuffer sink, long byteCount) throws IOException;
|
| OkBuffer.java | 35 * <p><strong>Moving data from one OkBuffer to another is fast.</strong> Instead
40 * each OkBuffer starts small. It consumes only the memory it needs to.
47 public final class OkBuffer implements BufferedSource, BufferedSink, Cloneable {
51 public OkBuffer() {
59 @Override public OkBuffer buffer() {
70 OkBuffer.this.write(data, offset, byteCount);
85 @Override public OkBuffer emitCompleteSegments() {
104 return OkBuffer.this.read(sink, offset, byteCount);
115 return OkBuffer.this + ".inputStream()";
407 @Override public OkBuffer write(ByteString byteString)
[all...] |
| BufferedSource.java | 28 OkBuffer buffer();
|
| RealBufferedSink.java | 22 public final OkBuffer buffer;
26 public RealBufferedSink(Sink sink, OkBuffer buffer) {
33 this(sink, new OkBuffer());
36 @Override public OkBuffer buffer() {
40 @Override public void write(OkBuffer source, long byteCount)
|
| RealBufferedSource.java | 25 public final OkBuffer buffer;
29 public RealBufferedSource(Source source, OkBuffer buffer) {
36 this(source, new OkBuffer());
39 @Override public OkBuffer buffer() {
43 @Override public long read(OkBuffer sink, long byteCount) throws IOException {
|
| BufferedSink.java | 27 OkBuffer buffer();
|
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/spdy/ |
| FrameWriter.java | 22 import okio.OkBuffer;
63 void data(boolean outFinished, int streamId, OkBuffer source, int byteCount) throws IOException;
65 void data(boolean outFinished, int streamId, OkBuffer source) throws IOException;
|
| SpdyStream.java | 27 import okio.OkBuffer;
341 private final OkBuffer receiveBuffer = new OkBuffer();
344 private final OkBuffer readBuffer = new OkBuffer();
362 @Override public long read(OkBuffer sink, long byteCount)
521 @Override public void write(OkBuffer source, long byteCount) throws IOException {
|
| /external/okhttp/okcurl/src/test/java/com/squareup/okhttp/curl/ |
| MainTest.java | 20 import okio.OkBuffer;
88 OkBuffer buffer = new OkBuffer();
|
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/ |
| RequestTest.java | 22 import okio.OkBuffer;
77 OkBuffer buffer = new OkBuffer();
|
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/ |
| Util.java | 41 import okio.OkBuffer;
213 public static OkBuffer readFully(Source source) throws IOException {
214 OkBuffer result = new OkBuffer();
225 OkBuffer skipBuffer = new OkBuffer();
|
