@Test public void testTwoBufferingSpliteratorsConsumedInParallel() { SeqBuffer<Integer> buffer = buffer(); List<Tuple2<Integer, Integer>> expected = Seq.zip(list, list).toList(); List<Tuple2<Integer, Integer>> actual = Seq.zip(buffer.seq(), buffer.seq()).toList(); assertEquals(expected, actual); assertEquals(list, buffer.seq().toList()); }
Seq<T> seq() { return Seq.seq(new BufferSpliterator()); }
SeqBuffer { Seq<T> seq() { return Seq.seq(new BufferSpliterator()); } }
SeqBuffer { Seq<T> seq() { return Seq.seq(new BufferSpliterator()); } private  SeqBuffer(Spliterator<T> source); }
SeqBuffer { Seq<T> seq() { return Seq.seq(new BufferSpliterator()); } private  SeqBuffer(Spliterator<T> source);  }
SeqBuffer { Seq<T> seq() { return Seq.seq(new BufferSpliterator()); } private  SeqBuffer(Spliterator<T> source);   }