Home
last modified time | relevance | path

Searched refs:BufferedSource (Results 1 – 25 of 55) sorted by relevance

123

/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/http/
DRealResponseBody.java21 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/
DRealBufferedSourceTest.java85 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()
DReadUtf8LineTest.java34 BufferedSource create(Buffer data); in create()
44 @Override public BufferedSource create(Buffer data) { in parameters()
53 @Override public BufferedSource create(Buffer data) { in parameters()
62 @Override public BufferedSource create(Buffer data) { in parameters()
86 private BufferedSource source;
DOkioTest.java44 BufferedSource source = Okio.buffer(Okio.source(file)); in readWriteFile()
63 BufferedSource source = Okio.buffer(Okio.source(file)); in appendFile()
DSocketTimeoutTest.java40 BufferedSource source = Okio.buffer(Okio.source(socket)); in readWithoutTimeout()
48 BufferedSource source = Okio.buffer(Okio.source(socket)); in readWithTimeout()
/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/
DResponseBody.java26 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()
DCache.java41 import okio.BufferedSource;
333 BufferedSource metadata = Okio.buffer(snapshot.getSource(ENTRY_METADATA)); in urls()
528 BufferedSource source = Okio.buffer(in); in Entry()
618 private List<Certificate> readCertificateList(BufferedSource source) throws IOException { in readCertificateList()
679 private static int readInt(BufferedSource source) throws IOException { in readInt()
694 private final BufferedSource bodySource;
725 @Override public BufferedSource source() { in source()
/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/framed/
DPushObserver.java20 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,
DNameValueBlockReader.java24 import okio.BufferedSource;
48 private final BufferedSource source;
50 public NameValueBlockReader(BufferedSource source) { in NameValueBlockReader()
DVariant.java20 import okio.BufferedSource;
31 FrameReader newReader(BufferedSource source, boolean client); in newReader()
DFrameReader.java22 import okio.BufferedSource;
31 void data(boolean inFinished, int streamId, BufferedSource source, int length) in data()
DHttp2.java24 import okio.BufferedSource;
79 @Override public FrameReader newReader(BufferedSource source, boolean client) { in newReader()
88 private final BufferedSource source;
95 Reader(BufferedSource source, int headerTableSize, boolean client) { in Reader()
593 private final BufferedSource source;
602 public ContinuationSource(BufferedSource source) { in ContinuationSource()
760 private static int readMedium(BufferedSource source) throws IOException {
DSpdy3.java27 import okio.BufferedSource;
98 @Override public FrameReader newReader(BufferedSource source, boolean client) { in newReader()
108 private final BufferedSource source;
112 Reader(BufferedSource source, boolean client) { in Reader()
/external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/
DSocksProxy.java36 import okio.BufferedSource;
102 BufferedSource fromSource = Okio.buffer(Okio.source(from)); in service()
114 private void hello(BufferedSource fromSource, BufferedSink fromSink) throws IOException { in hello()
142 private void acceptCommand(InetAddress fromAddress, BufferedSource fromSource, in acceptCommand()
193 BufferedSource toSource = Okio.buffer(Okio.source(toSocket)); in acceptCommand()
205 final BufferedSource source, final BufferedSink sink) { in transfer()
DWebPlatformUrlTestData.java23 import okio.BufferedSource;
87 public static List<WebPlatformUrlTestData> load(BufferedSource source) throws IOException { in load()
DWebPlatformUrlTest.java22 import okio.BufferedSource;
127 BufferedSource source = Okio.buffer(Okio.source( in loadTests()
/external/okhttp/okio/benchmarks/src/main/java/com/squareup/okio/benchmarks/
DBufferPerformanceBench.java44 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/samples/guide/src/main/java/com/squareup/okhttp/recipes/
DProgress.java26 import okio.BufferedSource;
72 private BufferedSource bufferedSource;
87 @Override public BufferedSource source() throws IOException { in source()
/external/okhttp/okhttp-ws/src/main/java/com/squareup/okhttp/internal/ws/
DWebSocketReader.java25 import okio.BufferedSource;
62 private final BufferedSource source;
81 public WebSocketReader(boolean isClient, BufferedSource source, FrameCallback frameCallback) { in WebSocketReader()
226 final BufferedSource source = Okio.buffer(framedMessageSource); in readMessageFrame()
236 @Override public BufferedSource source() throws IOException { in readMessageFrame()
DRealWebSocket.java31 import okio.BufferedSource;
55 public RealWebSocket(boolean isClient, BufferedSource source, BufferedSink sink, Random random, in RealWebSocket()
/external/okhttp/okio/
DCHANGELOG.md8 * New: `BufferedSource.indexOf(ByteString)` searches a source for the next
43 `BufferedSource` and `BufferedSink`. Unlike the alternatives, these methods
76 * New APIs: `BufferedSink.emit()`, `BufferedSource.request()` and `BufferedSink.indexOfElement()`.
84 `void readFully(byte[])` to `BufferedSource`.
111 * Methods to exhaust BufferedSource to byte[] and ByteString.
DREADME.md51 [`BufferedSource`][7] and [`BufferedSink`][8] interfaces. These interfaces give you
58 * **Easy to test.** The `Buffer` class implements both `BufferedSource` and
81 BufferedSource pngSource = Okio.buffer(Okio.source(in));
140 [7]: http://square.github.io/okio/okio/BufferedSource.html
/external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/framed/
DBaseTestHandler.java20 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/
DInflaterSource.java28 private final BufferedSource source;
48 InflaterSource(BufferedSource source, Inflater inflater) { in InflaterSource()
/external/okhttp/mockwebserver/src/main/java/com/squareup/okhttp/mockwebserver/
DMockWebServer.java75 import okio.BufferedSource;
480 BufferedSource source = Okio.buffer(Okio.source(socket));
504 BufferedSource source = Okio.buffer(Okio.source(raw));
519 private boolean processOneRequest(Socket socket, BufferedSource source, BufferedSink sink)
590 private RecordedRequest readRequest(Socket socket, BufferedSource source, BufferedSink sink,
660 private void handleWebSocketUpgrade(Socket socket, BufferedSource source, BufferedSink sink,
753 private void throttledTransfer(MockResponse policy, Socket socket, BufferedSource source,
801 private void readEmptyLine(BufferedSource source) throws IOException {

123