Lines Matching refs:downstream

245         protected final Sink<? super E_OUT> downstream;  field in Sink.ChainedReference
247 public ChainedReference(Sink<? super E_OUT> downstream) { in ChainedReference() argument
248 this.downstream = Objects.requireNonNull(downstream); in ChainedReference()
253 downstream.begin(size); in begin()
258 downstream.end(); in end()
263 return downstream.cancellationRequested(); in cancellationRequested()
277 protected final Sink<? super E_OUT> downstream; field in Sink.ChainedInt
279 public ChainedInt(Sink<? super E_OUT> downstream) { in ChainedInt() argument
280 this.downstream = Objects.requireNonNull(downstream); in ChainedInt()
285 downstream.begin(size); in begin()
290 downstream.end(); in end()
295 return downstream.cancellationRequested(); in cancellationRequested()
309 protected final Sink<? super E_OUT> downstream; field in Sink.ChainedLong
311 public ChainedLong(Sink<? super E_OUT> downstream) { in ChainedLong() argument
312 this.downstream = Objects.requireNonNull(downstream); in ChainedLong()
317 downstream.begin(size); in begin()
322 downstream.end(); in end()
327 return downstream.cancellationRequested(); in cancellationRequested()
341 protected final Sink<? super E_OUT> downstream; field in Sink.ChainedDouble
343 public ChainedDouble(Sink<? super E_OUT> downstream) { in ChainedDouble() argument
344 this.downstream = Objects.requireNonNull(downstream); in ChainedDouble()
349 downstream.begin(size); in begin()
354 downstream.end(); in end()
359 return downstream.cancellationRequested(); in cancellationRequested()