| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/http/ |
| HttpEngine.java | 51 import okio.Sink;
156 private Sink requestBodyOut;
307 public Sink getRequestBody() {
315 Sink requestBody = getRequestBody();
367 public HttpEngine recover(IOException e, Sink requestBodyOut) {
716 Sink requestBodyOut = httpStream.createRequestBody(request, request.body().contentLength());
767 Sink cacheBodyUnbuffered = cacheRequest.body();
776 @Override public long read(Buffer sink, long byteCount) throws IOException {
779 bytesRead = source.read(sink, byteCount);
796 sink.copyTo(cacheBody.buffer(), sink.size() - bytesRead, bytesRead)
[all...] |
| Http2xStream.java | 40 import okio.Sink;
122 @Override public Sink createRequestBody(Request request, long contentLength) throws IOException {
|
| /external/skia/tests/ |
| SkLinearBitmapPipelineTest.cpp | 117 struct Sink {
143 Sink listSink = {&listPoints};
144 Sink spanSink = {&spanPoints};
|
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/ |
| Cache.java | 46 import okio.Sink;
425 private Sink cacheOut;
427 private Sink body;
462 @Override public Sink body() {
578 BufferedSink sink = Okio.buffer(editor.newSink(ENTRY_METADATA)); local
580 sink.writeUtf8(url);
581 sink.writeByte('\n');
582 sink.writeUtf8(requestMethod);
583 sink.writeByte('\n');
584 sink.writeDecimalLong(varyHeaders.size())
[all...] |
| /external/okhttp/okio/okio/src/test/java/okio/ |
| OkioTest.java | 38 BufferedSink sink = Okio.buffer(Okio.sink(file)); local
39 sink.writeUtf8("Hello, java.io file!");
40 sink.close();
52 BufferedSink sink = Okio.buffer(Okio.appendingSink(file)); local
53 sink.writeUtf8("Hello, ");
54 sink.close();
58 sink = Okio.buffer(Okio.appendingSink(file));
59 sink.writeUtf8("java.io file!");
60 sink.close()
91 Sink sink = Okio.sink(out); local
104 Buffer sink = new Buffer(); local
[all...] |
| /prebuilts/tools/common/m2/repository/com/squareup/okio/okio/1.6.0/ |
| okio-1.6.0.jar | |
| /prebuilts/tools/common/m2/repository/com/squareup/okio/okio/1.8.0/ |
| okio-1.8.0.jar | |
| /external/icu/android_icu4j/src/main/java/android/icu/impl/ |
| DayPeriodRules.java | 77 private static final class DayPeriodRulesDataSink extends UResource.Sink {
211 private static class DayPeriodRulesCountSink extends UResource.Sink {
304 DayPeriodRulesDataSink sink = new DayPeriodRulesDataSink(data); local
305 rb.getAllItemsWithFallback("", sink);
|
| UResource.java | 451 * Sink for ICU resource bundle contents.
453 public static abstract class Sink {
|
| /external/icu/icu4j/main/classes/core/src/com/ibm/icu/impl/ |
| DayPeriodRules.java | 73 private static final class DayPeriodRulesDataSink extends UResource.Sink {
207 private static class DayPeriodRulesCountSink extends UResource.Sink {
300 DayPeriodRulesDataSink sink = new DayPeriodRulesDataSink(data); local
301 rb.getAllItemsWithFallback("", sink);
|
| UResource.java | 449 * Sink for ICU resource bundle contents.
451 public static abstract class Sink {
|
| /external/okhttp/okcurl/src/main/java/com/squareup/okhttp/curl/ |
| Main.java | 54 import okio.Sink;
157 Sink out = Okio.sink(System.out);
|
| /external/skia/dm/ |
| DM.cpp | 288 Gold(const SkString& sink, const SkString& src,
292 this->append(sink);
359 struct TaggedSink : public std::unique_ptr<Sink> {
808 static void push_sink(const SkCommandLineConfig& config, Sink* s) {
809 std::unique_ptr<Sink> sink(s);
811 // Try a simple Src as a canary. If it fails, skip this sink.
824 Error err = sink->draw(justOneRect, &bitmap, &stream, &log);
831 ts.reset(sink.release());
843 static Sink* create_sink(const GrContextOptions& grCtxOptions, const SkCommandLineConfig* config)
945 Sink* sink = create_sink(grCtxOptions, &config); local
1038 const TaggedSink& sink; member in struct:Task
[all...] |
| /libcore/ojluni/src/main/java/java/util/stream/ |
| StreamSpliterators.java | 87 * Sink chain for the downstream stages of the pipeline, ultimately
90 Sink<P_IN> bufferSink;
148 * Get an element from the source, pushing it into the sink chain,
182 * Initializes buffer, sink chain, and pusher for a shape-specific
200 * If the buffer is empty, push elements into the sink chain until
312 ph.wrapAndCopyInto((Sink<P_OUT>) consumer::accept, spliterator);
346 bufferSink = ph.wrapSink((Sink.OfInt) b::accept);
370 ph.wrapAndCopyInto((Sink.OfInt) consumer::accept, spliterator);
404 bufferSink = ph.wrapSink((Sink.OfLong) b::accept);
428 ph.wrapAndCopyInto((Sink.OfLong) consumer::accept, spliterator)
[all...] |
| Nodes.java | [all...] |
| /external/protobuf/php/ext/google/protobuf/ |
| upb.h | 7466 upb_sink sink; member in struct:upb::HandlerAttributes::upb::BufferHandle::upb::Handlers::upb::BytesHandler::upb::BytesSink::upb::BufferSource::__anon29705
[all...] |
| /external/protobuf/ruby/ext/google/protobuf_c/ |
| upb.h | 7769 upb_sink sink; member in struct:upb::HandlerAttributes::upb::BufferHandle::upb::Handlers::upb::BytesHandler::upb::BytesSink::upb::BufferSource::__anon29764
[all...] |
| /prebuilts/go/darwin-x86/test/ |
| escape_param.go | 14 var sink interface{} var
28 sink = param0(&i) // ERROR "&i escapes to heap$" "param0\(&i\) escapes to heap"
39 sink, _ = param1(&i, &j) // ERROR "&i escapes to heap$" "caller1 &j does not escape$"
58 sink = p // ERROR "p escapes to heap$"
84 sink = p // ERROR "p escapes to heap$"
103 sink = p // ERROR "p escapes to heap$"
108 sink = i // ERROR "i escapes to heap$"
118 sink = *i // ERROR "\*i escapes to heap$"
130 sink = **i // ERROR "\* \(\*i\) escapes to heap"
142 sink = **i // ERROR "\* \(\*i\) escapes to heap
[all...] |
| /prebuilts/go/linux-x86/test/ |
| escape_param.go | 14 var sink interface{} var
28 sink = param0(&i) // ERROR "&i escapes to heap$" "param0\(&i\) escapes to heap"
39 sink, _ = param1(&i, &j) // ERROR "&i escapes to heap$" "caller1 &j does not escape$"
58 sink = p // ERROR "p escapes to heap$"
84 sink = p // ERROR "p escapes to heap$"
103 sink = p // ERROR "p escapes to heap$"
108 sink = i // ERROR "i escapes to heap$"
118 sink = *i // ERROR "\*i escapes to heap$"
130 sink = **i // ERROR "\* \(\*i\) escapes to heap"
142 sink = **i // ERROR "\* \(\*i\) escapes to heap
[all...] |
| /external/okhttp/okhttp-ws-tests/src/test/java/com/squareup/okhttp/internal/ws/ |
| RealWebSocketTest.java | 31 import okio.Sink;
67 client = new RealWebSocket(true, server2client.source(), client2Server.sink(), random,
80 server = new RealWebSocket(false, client2Server.source(), server2client.sink(), random,
144 @Override public void writeTo(BufferedSink sink) throws IOException {
145 sink.writeUtf8("Hel").flush();
146 sink.writeUtf8("lo!").flush();
147 sink.close();
161 @Override public void writeTo(BufferedSink sink) throws IOException {
162 sink.writeUtf8("Hel").flush();
164 sink.writeUtf8("lo!").flush()
477 BufferedSink sink() { method
[all...] |
| /external/llvm/lib/Target/Mips/ |
| MipsSEISelLowering.cpp | [all...] |
| /external/icu/icu4c/source/i18n/ |
| collationbuilder.h | 40 class U_I18N_API CollationBuilder : public CollationRuleParser::Sink {
58 /** Implements CollationRuleParser::Sink. */
70 /** Implements CollationRuleParser::Sink. */
116 /** Implements CollationRuleParser::Sink. */
120 /** Implements CollationRuleParser::Sink. */
|
| collationruleparser.cpp | 48 CollationRuleParser::Sink::~Sink() {}
51 CollationRuleParser::Sink::suppressContractions(const UnicodeSet &, const char *&, UErrorCode &) {}
54 CollationRuleParser::Sink::optimize(const UnicodeSet &, const char *&, UErrorCode &) {}
63 sink(NULL), importer(NULL),
201 sink->addReset(resetStrength, str, errorReason, errorCode);
284 sink->addRelation(strength, prefix, str, extension, errorReason, errorCode);
307 sink->addRelation(strength, empty, UnicodeString(c), empty, errorReason, errorCode);
349 sink->addRelation(strength, empty, s, empty, errorReason, errorCode);
669 sink->optimize(set, errorReason, errorCode)
[all...] |
| /external/webrtc/talk/app/webrtc/ |
| rtpsender.cc | 56 void LocalAudioSinkAdapter::SetSink(cricket::AudioRenderer::Sink* sink) {
58 ASSERT(!sink || !sink_);
59 sink_ = sink;
194 // Use the renderer if the audio track has one, otherwise use the sink
|
| /external/icu/android_icu4j/src/main/java/android/icu/util/ |
| MeasureUnit.java | 245 * Sink for enumerating the available measure units.
247 private static final class MeasureUnitSink extends UResource.Sink {
268 * Sink for enumerating the currency numeric codes.
270 private static final class CurrencyNumericCodeSink extends UResource.Sink {
[all...] |
