One more pass on flatMap/mapMulti

[Brian Goetz]

Downstream:

     /** A collector for values associated with a given input.  Values 
can be
      * yielded individually, or in aggregates such as collections, 
arrays, or
      * streams; aggregates are flattened, so that yielding an array 
containing
      * [1, 2] is equivalent to yield(1); yield(2).
      */
     interface Downstream<U> {
         void yield(U element);

         default void yield(Collection<U> collection) {
             for (U u : collection)
                 yield(u);
         }

         default void yield(U[] array) {
             for (U u : array)
                 yield(u);
         }

         default void yield(Stream<U> stream) {
             stream.forEach(this::yield);
         }
     }

The basic idea is that this is a collector for values.  It was at one 
point called "collector" but now we have something else called Collector.

On 1/10/2013 10:35 AM, Remi Forax wrote:
> On 01/10/2013 04:10 PM, Brian Goetz wrote:
>> One more simplification: we don't really need a custom type SAM for
>> Multifunction.  We can rewrite mapMulti as:
>>
>>   mapMulti(BiBlock<Downstream<T>, T>))
>>
>> and move the Downstream class declaration to Stream, and
>> XxxMultifunction go away.
>
> what Downstream is ?
>
>>
>>
>> mapMulti is still not a great name.  How about "explode" ?
>>
>
> yes, explode is better.
>
> Rémi
>