util/stream/Sink.java

77  * sends some elements "downstream" -- into the {@code Sink} for the mapping
78  * stage, which in turn sends integral values downstream into the {@code Sink}
81  * the correct {@code accept} method on its downstream {@code Sink}.  Similarly,
92  * {@code Sink.OfInt}, but also maintain a {@code downstream} field which
93  * represents the downstream {@code Sink}, and implement the methods
95  * delegate to the downstream {@code Sink}.  Most implementations of
102  *             downstream.accept(mapper.applyAsInt(u));
108  * to receive elements of type {@code U} as input, and pass the downstream sink
110  * must call the {@code accept(int)} method when emitting values to the downstream.
112  * {@code int} and passes the resulting value to the downstream {@code Sink}.
122      * @param size The exact size of the data to be pushed downstream, if
132      * stateful, it should send any stored state downstream at this time, and
239      * downstream {@code Sink}.  This implementation takes a downstream
242      * {@code accept()} method on the downstream {@code Sink}.
245         protected final Sink<? super E_OUT> downstream;
247         public ChainedReference(Sink<? super E_OUT> downstream) {
248             this.downstream = Objects.requireNonNull(downstream);
253             downstream.begin(size);
258             downstream.end();
263             return downstream.cancellationRequested();
271      * downstream {@code Sink}.  This implementation takes a downstream
274      * {@code accept()} method on the downstream {@code Sink}.
277         protected final Sink<? super E_OUT> downstream;
279         public ChainedInt(Sink<? super E_OUT> downstream) {
280             this.downstream = Objects.requireNonNull(downstream);
285             downstream.begin(size);
290             downstream.end();
295             return downstream.cancellationRequested();
303      * downstream {@code Sink}.  This implementation takes a downstream
306      * {@code accept()} method on the downstream {@code Sink}.
309         protected final Sink<? super E_OUT> downstream;
311         public ChainedLong(Sink<? super E_OUT> downstream) {
312             this.downstream = Objects.requireNonNull(downstream);
317             downstream.begin(size);
322             downstream.end();
327             return downstream.cancellationRequested();
335      * downstream {@code Sink}.  This implementation takes a downstream
338      * {@code accept()} method on the downstream {@code Sink}.
341         protected final Sink<? super E_OUT> downstream;
343         public ChainedDouble(Sink<? super E_OUT> downstream) {
344             this.downstream = Objects.requireNonNull(downstream);
349             downstream.begin(size);
354             downstream.end();
359             return downstream.cancellationRequested();