| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/http/ |
| D | RealResponseBody.java | 21 import okio.BufferedSource;
25 private final BufferedSource source;
27 public RealResponseBody(Headers headers, BufferedSource source) { in RealResponseBody()
41 @Override public BufferedSource source() { in source()
|
| /external/okhttp/okio/okio/src/test/java/okio/ |
| D | RealBufferedSourceTest.java | 85 BufferedSource bufferedSource = new RealBufferedSource(source); in requireTracksBufferFirst()
97 BufferedSource bufferedSource = new RealBufferedSource(source); in requireIncludesBufferBytes()
108 BufferedSource bufferedSource = new RealBufferedSource(source); in requireInsufficientData()
122 BufferedSource bufferedSource = new RealBufferedSource(source); in requireReadsOneSegmentAtATime()
133 BufferedSource bufferedSource = new RealBufferedSource(source); in skipReadsOneSegmentAtATime()
143 BufferedSource bufferedSource = new RealBufferedSource(source); in skipTracksBufferFirst()
153 BufferedSource bufferedSource = new RealBufferedSource(source); in operationsAfterClose()
211 BufferedSource bufferedSource = Okio.buffer((Source) source); in readAllReadsOneSegmentAtATime()
|
| D | ReadUtf8LineTest.java | 34 BufferedSource create(Buffer data); in create()
43 @Override public BufferedSource create(Buffer data) { in parameters()
52 @Override public BufferedSource create(Buffer data) { in parameters()
61 @Override public BufferedSource create(Buffer data) { in parameters()
82 private BufferedSource source;
|
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/ |
| D | ResponseBody.java | 26 import okio.BufferedSource;
46 public abstract BufferedSource source() throws IOException; in source()
54 BufferedSource source = source(); in bytes()
120 final MediaType contentType, final long contentLength, final BufferedSource content) { in create()
131 @Override public BufferedSource source() { in create()
|
| D | Cache.java | 41 import okio.BufferedSource;
312 BufferedSource metadata = Okio.buffer(snapshot.getSource(ENTRY_METADATA)); in urls()
507 BufferedSource source = Okio.buffer(in); in Entry()
597 private List<Certificate> readCertificateList(BufferedSource source) throws IOException { in readCertificateList()
658 private static int readInt(BufferedSource source) throws IOException { in readInt()
673 private final BufferedSource bodySource;
704 @Override public BufferedSource source() { in source()
|
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/spdy/ |
| D | PushObserver.java | 20 import okio.BufferedSource;
70 boolean onData(int streamId, BufferedSource source, int byteCount, boolean last) in onData()
86 @Override public boolean onData(int streamId, BufferedSource source, int byteCount,
|
| D | NameValueBlockReader.java | 24 import okio.BufferedSource;
48 private final BufferedSource source;
50 public NameValueBlockReader(BufferedSource source) { in NameValueBlockReader()
|
| D | Variant.java | 20 import okio.BufferedSource;
31 FrameReader newReader(BufferedSource source, boolean client); in newReader()
|
| D | FrameReader.java | 22 import okio.BufferedSource;
31 void data(boolean inFinished, int streamId, BufferedSource source, int length) in data()
|
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/ |
| D | SocksProxy.java | 36 import okio.BufferedSource;
100 BufferedSource fromSource = Okio.buffer(Okio.source(from)); in service()
112 private void hello(BufferedSource fromSource, BufferedSink fromSink) throws IOException { in hello()
140 private void acceptCommand(InetAddress fromAddress, BufferedSource fromSource, in acceptCommand()
188 BufferedSource toSource = Okio.buffer(Okio.source(toSocket)); in acceptCommand()
200 final BufferedSource source, final BufferedSink sink) { in transfer()
|
| D | WebPlatformUrlTestData.java | 23 import okio.BufferedSource;
86 public static List<WebPlatformUrlTestData> load(BufferedSource source) throws IOException { in load()
|
| /external/okhttp/okio/benchmarks/src/main/java/com/squareup/okio/benchmarks/ |
| D | BufferPerformanceBench.java | 44 import okio.BufferedSource;
182 try (BufferedSource source = Okio.buffer(Okio.source(OriginPath))) { in storeSourceData()
242 public BufferedSource receive(byte[] bytes) throws IOException { in receive()
246 public BufferedSource transmit(byte[] bytes) throws IOException { in transmit()
287 protected BufferedSource transmit(byte[] bytes, int maxChunkSize) throws IOException { in transmit()
292 private BufferedSource writeChunked(Buffer buffer, byte[] bytes, final int chunkSize) { in writeChunked()
|
| /external/okhttp/okhttp-ws-tests/src/test/java/com/squareup/okhttp/ws/ |
| D | AutobahnTester.java | 30 import okio.BufferedSource;
78 @Override public void onMessage(BufferedSource payload, final WebSocket.PayloadType type) in runTest()
125 @Override public void onMessage(BufferedSource payload, WebSocket.PayloadType type) in getTestCount()
164 @Override public void onMessage(BufferedSource payload, WebSocket.PayloadType type) in updateReports()
|
| D | WebSocketRecorder.java | 26 import okio.BufferedSource;
36 void onMessage(BufferedSource payload, WebSocket.PayloadType type) throws IOException; in onMessage()
50 @Override public void onMessage(BufferedSource source, WebSocket.PayloadType type) in onMessage()
|
| /external/okhttp/samples/guide/src/main/java/com/squareup/okhttp/recipes/ |
| D | Progress.java | 26 import okio.BufferedSource;
72 private BufferedSource bufferedSource;
87 @Override public BufferedSource source() throws IOException { in source()
|
| D | WebSocketEcho.java | 11 import okio.BufferedSource;
38 @Override public void onMessage(BufferedSource payload, PayloadType type) throws IOException { in onMessage()
|
| /external/okhttp/okhttp-ws/src/main/java/com/squareup/okhttp/ws/ |
| D | WebSocketListener.java | 22 import okio.BufferedSource;
38 void onMessage(BufferedSource payload, PayloadType type) throws IOException; in onMessage()
|
| D | WebSocketCall.java | 38 import okio.BufferedSource;
175 BufferedSource source = Internal.instance.connectionRawSource(connection); in createWebSocket()
197 static RealWebSocket create(Response response, Connection connection, BufferedSource source, in create()
211 private ConnectionWebSocket(Connection connection, BufferedSource source, BufferedSink sink, in ConnectionWebSocket()
|
| /external/okhttp/okhttp-ws-tests/src/test/java/com/squareup/okhttp/internal/ws/ |
| D | WebSocketReaderTest.java | 25 import okio.BufferedSource;
154 @Override public void onMessage(BufferedSource payload, PayloadType type) throws IOException { in serverHelloTwoChunks()
254 @Override public void onMessage(BufferedSource payload, PayloadType type) throws IOException { in noCloseErrors()
272 @Override public void onMessage(BufferedSource payload, PayloadType type) throws IOException { in closeExhaustsMessage()
294 @Override public void onMessage(BufferedSource payload, PayloadType type) throws IOException { in closeExhaustsMessageOverControlFrames()
314 @Override public void onMessage(BufferedSource payload, PayloadType type) throws IOException { in closedMessageSourceThrows()
|
| /external/okhttp/okio/ |
| D | CHANGELOG.md | 9 `BufferedSource` and `BufferedSink`. Unlike the alternatives, these methods
41 * New APIs: `BufferedSink.emit()`, `BufferedSource.request()` and `BufferedSink.indexOfElement()`.
49 `void readFully(byte[])` to `BufferedSource`.
76 * Methods to exhaust BufferedSource to byte[] and ByteString.
|
| /external/okhttp/okhttp-ws/src/main/java/com/squareup/okhttp/internal/ws/ |
| D | RealWebSocket.java | 27 import okio.BufferedSource;
46 public RealWebSocket(boolean isClient, BufferedSource source, BufferedSink sink, Random random, in RealWebSocket()
52 @Override public void onMessage(BufferedSource source, PayloadType type) throws IOException { in RealWebSocket()
|
| D | WebSocketReader.java | 22 import okio.BufferedSource;
53 void onMessage(BufferedSource source, PayloadType type) throws IOException; in onMessage()
60 private final BufferedSource source;
79 public WebSocketReader(boolean isClient, BufferedSource source, FrameCallback frameCallback) { in WebSocketReader()
|
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/spdy/ |
| D | BaseTestHandler.java | 20 import okio.BufferedSource;
26 @Override public void data(boolean inFinished, int streamId, BufferedSource source, int length) in data()
|
| /external/okhttp/okio/okio/src/main/java/okio/ |
| D | InflaterSource.java | 28 private final BufferedSource source;
48 InflaterSource(BufferedSource source, Inflater inflater) { in InflaterSource()
|
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/ |
| D | Internal.java | 34 import okio.BufferedSource;
92 public abstract BufferedSource connectionRawSource(Connection connection); in connectionRawSource()
|