Cancelable streams

[Joe Bowbeer]

> Plus, the ability to query the gate to determine whether the pipeline
finished because it was out of elements, or because the gate was manually
closed.

In my view, closing the gate doesn't "finish" the stream, it just stalls
it.  Gates open and close.  They can be used to delay the start until the
appointed time, regulate the passage of elements, pause, resume, etc.



On Sun, Nov 4, 2012 at 8:13 PM, Brian Goetz <brian.goetz at oracle.com> wrote:

> > In essence I think you want to insert a "gate" operation into the
> pipeline - while the gate is open elements can be read from the stream, but
> when it is closed they can not. The question then becomes how you control
> the gate, either from within the pipeline (predicate based) or externally
> (time-trigerred callback).
>
> Yes, that is exactly what I am suggesting.  Plus, the ability to query the
> gate to determine whether the pipeline finished because it was out of
> elements, or because the gate was manually closed.
>
>