| /external/okhttp/okio/okio/src/main/java/okio/ |
| GzipSink.java | 25 * A sink that uses <a href="http://www.ietf.org/rfc/rfc1952.txt">GZIP</a> to
26 * compress written data to another sink.
38 public final class GzipSink implements Sink {
39 /** Sink into which the GZIP format is written. */
40 private final BufferedSink sink; field in class:GzipSink
46 * The deflater sink takes care of moving data between decompressed source and
47 * compressed sink buffers.
56 public GzipSink(Sink sink) {
57 if (sink == null) throw new IllegalArgumentException("sink == null")
[all...] |
| BufferedSink.java | 23 * A sink that keeps a buffer internally so that callers can do small writes
26 public interface BufferedSink extends Sink {
27 /** Returns this sink's internal buffer. */
34 * this sink.
45 * Removes all bytes from {@code source} and appends them to this sink. Returns the
50 /** Removes {@code byteCount} bytes from {@code source} and appends them to this sink. */
53 /** Encodes {@code string} in UTF-8 and writes it to this sink. */
58 * UTF-8 and writes it to this sink.
62 /** Encodes {@code codePoint} in UTF-8 and writes it to this sink. */
65 /** Encodes {@code string} in {@code charset} and writes it to this sink. *
[all...] |
| BufferedSource.java | 110 * Removes up to {@code sink.length} bytes from this and copies them into {@code sink}.
113 int read(byte[] sink) throws IOException;
116 * Removes exactly {@code sink.length} bytes from this and copies them into {@code sink}.
119 void readFully(byte[] sink) throws IOException;
122 * Removes up to {@code byteCount} bytes from this and copies them into {@code sink} at
125 int read(byte[] sink, int offset, int byteCount) throws IOException;
129 * {@code sink}. Throws an {@link java.io.EOFException} if the requested
132 void readFully(Buffer sink, long byteCount) throws IOException
[all...] |
| RealBufferedSink.java | 25 public final Sink sink; field in class:RealBufferedSink
28 public RealBufferedSink(Sink sink, Buffer buffer) {
29 if (sink == null) throw new IllegalArgumentException("sink == null");
31 this.sink = sink;
34 public RealBufferedSink(Sink sink) {
[all...] |
| /external/webrtc/talk/app/webrtc/ |
| rtpsender.h | 47 // LocalAudioSinkAdapter receives data callback as a sink to the local
48 // AudioTrack, and passes the data to the sink of AudioRenderer.
64 void SetSink(cricket::AudioRenderer::Sink* sink) override;
66 cricket::AudioRenderer::Sink* sink_;
|
| remoteaudiosource.h | 61 void AddSink(AudioTrackSinkInterface* sink) override;
62 void RemoveSink(AudioTrackSinkInterface* sink) override;
80 class Sink;
|
| /libcore/ojluni/src/test/java/util/stream/bootlib/java/util/stream/ |
| TestFlagExpectedOp.java | 104 public Sink<T> opWrapSink(int flags, boolean parallel, Sink upstream) {
|
| /libcore/ojluni/src/test/java/util/stream/testlib/org/openjdk/testlib/java/util/stream/ |
| TestFlagExpectedOp.java | 105 public Sink<T> opWrapSink(int flags, boolean parallel, Sink upstream) {
|
| /external/okhttp/okio/okio/src/test/java/okio/ |
| MockSink.java | 28 /** A scriptable sink. Like Mockito, but worse and requiring less configuration. */
29 class MockSink implements Sink {
|
| SocketTimeoutTest.java | 60 Sink sink = Okio.buffer(Okio.sink(socket)); local
61 sink.timeout().timeout(500, TimeUnit.MILLISECONDS);
63 sink.write(new Buffer().write(data), data.length);
64 sink.flush();
70 Sink sink = Okio.sink(socket); local
71 sink.timeout().timeout(500, TimeUnit.MILLISECONDS)
[all...] |
| InflaterSourceTest.java | 98 Sink sink = Okio.sink(new DeflaterOutputStream(result.outputStream())); local
99 sink.write(new Buffer().write(source), source.size());
100 sink.close();
|
| /libcore/ojluni/src/main/java/java/util/stream/ |
| MatchOps.java | 112 class MatchSink extends BooleanTerminalSink<Integer> implements Sink.OfInt {
141 class MatchSink extends BooleanTerminalSink<Long> implements Sink.OfLong {
171 class MatchSink extends BooleanTerminalSink<Double> implements Sink.OfDouble {
206 * @param sinkSupplier {@code Supplier} for a {@code Sink} of the
247 * Boolean specific terminal sink to avoid the boxing costs when returning
252 private static abstract class BooleanTerminalSink<T> implements Sink<T> {
|
| ReduceOps.java | 248 implements AccumulatingSink<Integer, Integer, ReducingSink>, Sink.OfInt {
290 implements AccumulatingSink<Integer, OptionalInt, ReducingSink>, Sink.OfInt {
348 implements AccumulatingSink<Integer, R, ReducingSink>, Sink.OfInt {
384 implements AccumulatingSink<Long, Long, ReducingSink>, Sink.OfLong {
426 implements AccumulatingSink<Long, OptionalLong, ReducingSink>, Sink.OfLong {
484 implements AccumulatingSink<Long, R, ReducingSink>, Sink.OfLong {
520 implements AccumulatingSink<Double, Double, ReducingSink>, Sink.OfDouble {
562 implements AccumulatingSink<Double, OptionalDouble, ReducingSink>, Sink.OfDouble {
620 implements AccumulatingSink<Double, R, ReducingSink>, Sink.OfDouble {
|
| Node.java | 186 * A mutable builder for a {@code Node} that implements {@link Sink}, which
189 interface Builder<T> extends Sink<T> {
193 * pushed and signalled with an invocation of {@link Sink#end()}.
202 interface OfInt extends Node.Builder<Integer>, Sink.OfInt {
210 interface OfLong extends Node.Builder<Long>, Sink.OfLong {
218 interface OfDouble extends Node.Builder<Double>, Sink.OfDouble {
|
| FindOps.java | 199 implements Sink.OfInt {
202 // Boxing is OK here, since few values will actually flow into the sink
214 implements Sink.OfLong {
217 // Boxing is OK here, since few values will actually flow into the sink
229 implements Sink.OfDouble {
232 // Boxing is OK here, since few values will actually flow into the sink
|
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/http/ |
| Http1xStream.java | 34 import okio.Sink;
47 * <li>Open a sink to write the request body. Either {@link
49 * <li>Write to and then close that sink.
73 private final BufferedSink sink; field in class:Http1xStream
77 public Http1xStream(StreamAllocation streamAllocation, BufferedSource source, BufferedSink sink) {
80 this.sink = sink;
87 @Override public Sink createRequestBody(Request request, long contentLength) throws IOException {
161 sink.flush();
167 sink.writeUtf8(requestLine).writeUtf8("\r\n")
[all...] |
| StreamAllocation.java | 34 import okio.Sink;
104 resultConnection.sink.timeout().timeout(writeTimeout, MILLISECONDS);
105 resultStream = new Http1xStream(this, resultConnection.source, resultConnection.sink);
333 public boolean recover(IOException e, Sink requestBodyOut) {
|
| /external/icu/android_icu4j/src/main/java/android/icu/impl/ |
| CalendarUtil.java | 61 private static final class CalendarPreferences extends UResource.Sink {
|
| /external/icu/icu4j/main/classes/core/src/com/ibm/icu/impl/ |
| CalendarUtil.java | 59 private static final class CalendarPreferences extends UResource.Sink {
|
| /external/okhttp/okhttp-ws-tests/src/test/java/com/squareup/okhttp/internal/ws/ |
| WebSocketWriterTest.java | 25 import okio.Sink;
64 BufferedSink sink = Okio.buffer(serverWriter.newMessageSink(OPCODE_TEXT)); local
66 sink.writeUtf8("Hel").flush();
69 sink.writeUtf8("lo").flush();
72 sink.close();
77 BufferedSink sink = Okio.buffer(serverWriter.newMessageSink(OPCODE_TEXT)); local
79 sink.writeUtf8("Hel").flush();
82 sink.writeUtf8("lo").close();
87 Sink sink = serverWriter.newMessageSink(OPCODE_TEXT) local
103 BufferedSink sink = Okio.buffer(clientWriter.newMessageSink(OPCODE_TEXT)); local
116 BufferedSink sink = Okio.buffer(serverWriter.newMessageSink(OPCODE_BINARY)); local
131 Sink sink = serverWriter.newMessageSink(OPCODE_BINARY); local
151 Sink sink = serverWriter.newMessageSink(OPCODE_BINARY); local
178 BufferedSink sink = Okio.buffer(clientWriter.newMessageSink(OPCODE_BINARY)); local
[all...] |
| /libcore/ojluni/src/test/java/util/stream/boottest/java/util/stream/ |
| FlagOpTest.java | 71 public Sink<T> opWrapSink(int flags, boolean parallel, Sink sink) {
78 return sink;
264 public Sink<T> opWrapSink(int flags, boolean parallel, Sink upstream) {
|
| /external/okhttp/okhttp-ws/src/main/java/com/squareup/okhttp/internal/ws/ |
| WebSocketWriter.java | 23 import okio.Sink;
51 private final BufferedSink sink; field in class:WebSocketWriter
63 public WebSocketWriter(boolean isClient, BufferedSink sink, Random random) {
64 if (sink == null) throw new NullPointerException("sink == null");
67 this.sink = sink;
131 sink.writeByte(b0);
136 sink.writeByte(b1);
139 sink.write(maskKey)
[all...] |
| /external/okhttp/okio/benchmarks/src/main/java/com/squareup/okio/benchmarks/ |
| BufferPerformanceBench.java | 46 import okio.Sink;
307 private static final Sink NullSink = new Sink() {
|
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/framed/ |
| FramedStream.java | 28 import okio.Sink;
65 final FramedDataSink sink; field in class:FramedStream
86 this.sink = new FramedDataSink();
88 this.sink.finished = outFinished;
111 && (sink.finished || sink.closed)
175 this.sink.finished = true;
200 * Returns a sink that can be used to write data to the peer.
205 public Sink getSink() {
208 throw new IllegalStateException("reply before requesting the sink");
[all...] |
| /prebuilts/tools/common/m2/repository/com/squareup/okio/okio/1.9.0/ |
| okio-1.9.0.jar | |
