| /libcore/ojluni/src/test/java/util/stream/testlib/org/openjdk/testlib/java/util/stream/ |
| StatefulTestOp.java | 41 public Sink opWrapSink(int flags, Sink sink) {
42 return op.opWrapSink(flags, isParallel(), sink);
61 public Sink opWrapSink(int flags, Sink sink) {
62 return op.opWrapSink(flags, isParallel(), sink);
81 public Sink opWrapSink(int flags, Sink sink)
[all...] |
| CollectorOps.java | 65 public Sink<E_IN> opWrapSink(int flags, boolean parallel, Sink<E_IN> sink) {
66 return sink;
|
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/io/ |
| FileSystem.java | 22 import okio.Sink;
47 @Override public Sink sink(File file) throws FileNotFoundException {
49 return Okio.sink(file);
53 return Okio.sink(file);
57 @Override public Sink appendingSink(File file) throws FileNotFoundException {
112 Sink sink(File file) throws FileNotFoundException; method in interface:FileSystem
118 Sink appendingSink(File file) throws FileNotFoundException;
|
| /libcore/ojluni/src/main/java/java/util/stream/ |
| DoublePipeline.java | 95 * Adapt a {@code Sink<Double> to a {@code DoubleConsumer}, ideally simply
98 private static DoubleConsumer adapt(Sink<Double> sink) {
99 if (sink instanceof DoubleConsumer) {
100 return (DoubleConsumer) sink;
104 "using DoubleStream.adapt(Sink<Double> s)");
105 return sink::accept;
157 public final void forEachWithCancel(Spliterator<Double> spliterator, Sink<Double> sink) {
159 DoubleConsumer adaptedSink = adapt(sink);
[all...] |
| ReferencePipeline.java | 126 public final void forEachWithCancel(Spliterator<P_OUT> spliterator, Sink<P_OUT> sink) {
127 do { } while (!sink.cancellationRequested() && spliterator.tryAdvance(sink));
154 public Sink<P_OUT> opWrapSink(int flags, Sink<P_OUT> sink) {
155 return sink;
166 public Sink<P_OUT> opWrapSink(int flags, Sink<P_OUT> sink)
[all...] |
| IntPipeline.java | 96 * Adapt a {@code Sink<Integer> to an {@code IntConsumer}, ideally simply
99 private static IntConsumer adapt(Sink<Integer> sink) {
100 if (sink instanceof IntConsumer) {
101 return (IntConsumer) sink;
106 "using IntStream.adapt(Sink<Integer> s)");
107 return sink::accept;
160 public final void forEachWithCancel(Spliterator<Integer> spliterator, Sink<Integer> sink) {
162 IntConsumer adaptedSink = adapt(sink);
[all...] |
| SortedOps.java | 133 public Sink<T> opWrapSink(int flags, Sink<T> sink) {
134 Objects.requireNonNull(sink);
139 return sink;
141 return new SizedRefSortingSink<>(sink, comparator);
143 return new RefSortingSink<>(sink, comparator);
174 public Sink<Integer> opWrapSink(int flags, Sink<Integer> sink) {
[all...] |
| DistinctOps.java | 119 public Sink<T> opWrapSink(int flags, Sink<T> sink) {
120 Objects.requireNonNull(sink);
123 return sink;
125 return new Sink.ChainedReference<T, T>(sink) {
156 return new Sink.ChainedReference<T, T>(sink) {
|
| ForEachOps.java | 190 implements Sink.OfInt {
211 implements Sink.OfLong {
232 implements Sink.OfDouble {
256 private final Sink<S> sink; field in class:ForEachOps.ForEachTask
262 Sink<S> sink) {
264 this.sink = sink;
273 this.sink = parent.sink
[all...] |
| SliceOps.java | 189 public Sink<T> opWrapSink(int flags, Sink<T> sink) {
190 return new Sink.ChainedReference<T, T>(sink) {
298 public Sink<Integer> opWrapSink(int flags, Sink<Integer> sink) {
299 return new Sink.ChainedInt<Integer>(sink) {
[all...] |
| AbstractPipeline.java | 471 final <P_IN, S extends Sink<E_OUT>> S wrapAndCopyInto(S sink, Spliterator<P_IN> spliterator) {
472 copyInto(wrapSink(Objects.requireNonNull(sink)), spliterator);
473 return sink;
477 final <P_IN> void copyInto(Sink<P_IN> wrappedSink, Spliterator<P_IN> spliterator) {
492 final <P_IN> void copyIntoWithCancel(Sink<P_IN> wrappedSink, Spliterator<P_IN> spliterator) {
514 public final <P_IN> Sink<P_IN> wrapSink(Sink<E_OUT> sink) {
515 Objects.requireNonNull(sink);
[all...] |
| /frameworks/base/location/lib/java/com/android/location/provider/ |
| ActivityRecognitionProvider.java | 34 private final HashSet<Sink> mSinkSet = new HashSet<>();
56 public interface Sink {
75 public void registerSink(Sink sink) {
76 Preconditions.checkNotNull(sink);
78 mSinkSet.add(sink);
84 public void unregisterSink(Sink sink) {
85 Preconditions.checkNotNull(sink);
87 mSinkSet.remove(sink);
[all...] |
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/ |
| FaultHidingSink.java | 6 import okio.Sink;
8 /** A sink that never throws IOExceptions, even if the underlying sink does. */
12 public FaultHidingSink(Sink delegate) {
|
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/ |
| FaultyFileSystem.java | 26 import okio.Sink;
49 @Override public Sink sink(File file) throws FileNotFoundException { method in class:FaultyFileSystem
50 return new FaultySink(delegate.sink(file), file);
53 @Override public Sink appendingSink(File file) throws FileNotFoundException {
80 public FaultySink(Sink delegate, File file) {
|
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/http/ |
| RetryableSink.java | 22 import okio.Sink;
32 public final class RetryableSink implements Sink {
74 public void writeToSocket(Sink socketOut) throws IOException {
|
| /prebuilts/tools/common/m2/repository/org/apache/maven/doxia/doxia-sink-api/1.0/ |
| doxia-sink-api-1.0.jar | |
| /external/okhttp/okhttp-testing-support/src/main/java/com/squareup/okhttp/internal/io/ |
| InMemoryFileSystem.java | 30 import okio.Sink;
40 private final Map<Sink, File> openSinks = new IdentityHashMap<>();
57 openResources.add("Sink for " + file);
83 @Override public Sink sink(File file) throws FileNotFoundException {
84 return sink(file, false);
87 @Override public Sink appendingSink(File file) throws FileNotFoundException {
88 return sink(file, true);
91 private Sink sink(File file, boolean appending)
[all...] |
| /external/okhttp/okio/okio/src/main/java/okio/ |
| Okio.java | 51 * Returns a new sink that buffers writes to {@code sink}. The returned sink
52 * will batch writes to {@code sink}. Use this wherever you write to a sink to
55 public static BufferedSink buffer(Sink sink) {
56 if (sink == null) throw new IllegalArgumentException("sink == null");
57 return new RealBufferedSink(sink);
61 public static Sink sink(OutputStream out) { method in class:Okio
65 private static Sink sink(final OutputStream out, final Timeout timeout) { method in class:Okio
[all...] |
| AsyncTimeout.java | 31 * <p>Use {@link #sink} and {@link #source} to apply this timeout to a stream.
145 * Returns a new sink that delegates to {@code sink}, using this to implement
147 * {@code sink}'s current operation.
149 public final Sink sink(final Sink sink) { method in class:AsyncTimeout
150 return new Sink() {
155 sink.write(source, byteCount)
[all...] |
| DeflaterSink.java | 24 * A sink that uses <a href="http://tools.ietf.org/html/rfc1951">DEFLATE</a> to
37 public final class DeflaterSink implements Sink {
38 private final BufferedSink sink; field in class:DeflaterSink
42 public DeflaterSink(Sink sink, Deflater deflater) {
43 this(Okio.buffer(sink), deflater);
51 DeflaterSink(BufferedSink sink, Deflater deflater) {
52 if (sink == null) throw new IllegalArgumentException("source == null");
54 this.sink = sink;
[all...] |
| /external/webrtc/talk/app/webrtc/ |
| remoteaudiosource.cc | 57 class RemoteAudioSource::Sink : public AudioSinkInterface {
59 explicit Sink(RemoteAudioSource* source) : source_(source) {}
60 ~Sink() override { source_->OnAudioProviderGone(); }
69 RTC_DISALLOW_IMPLICIT_CONSTRUCTORS(Sink);
100 ssrc, rtc::scoped_ptr<AudioSinkInterface>(new Sink(this)));
132 void RemoteAudioSource::AddSink(AudioTrackSinkInterface* sink) {
134 RTC_DCHECK(sink);
137 LOG(LS_ERROR) << "Can't register sink as the source isn't live.";
142 RTC_DCHECK(std::find(sinks_.begin(), sinks_.end(), sink) == sinks_.end());
143 sinks_.push_back(sink);
[all...] |
| /external/icu/icu4c/source/i18n/ |
| collationruleparser.h | 71 class U_I18N_API Sink : public UObject {
73 virtual ~Sink();
106 * The Sink must be set before parsing.
113 * Sets the pointer to a Sink object.
116 void setSink(Sink *sinkAlias) {
117 sink = sinkAlias;
188 Sink *sink; member in class:CollationRuleParser
|
| /libcore/ojluni/src/test/java/util/stream/bootlib/java/util/stream/ |
| CollectorOps.java | 64 public Sink<E_IN> opWrapSink(int flags, boolean parallel, Sink<E_IN> sink) {
65 return sink;
|
| /external/okhttp/okio/okio/src/test/java/okio/ |
| AsyncTimeoutTest.java | 183 Sink sink = new ForwardingSink(new Buffer()) { local
194 Sink timeoutSink = timeout.sink(sink);
204 @Override public long read(Buffer sink, long byteCount) throws IOException {
224 Sink sink = new ForwardingSink(new Buffer()) { local
236 Sink timeoutSink = timeout.sink(sink)
247 Sink sink = new ForwardingSink(new Buffer()) { local
[all...] |
| /external/okhttp/okhttp-android-support/src/main/java/com/squareup/okhttp/internal/huc/ |
| CacheAdapter.java | 32 import okio.Sink;
62 @Override public Sink body() throws IOException {
64 return body != null ? Okio.sink(body) : null;
|
