Searched refs:resultPipe (Results 1 – 1 of 1) sorted by relevance
106 val resultPipe = ArrayBlockingQueue<Future<List<U>>>(1024, false) in par_map() constant120 resultPipe.put(future) in par_map()122 resultPipe.put(endOfStreamMarker) in par_map()134 val next = resultPipe.take() in par_map()