Searched refs:endOfStreamMarker (Results 1 – 1 of 1) sorted by relevance
105 val endOfStreamMarker = CompletableFuture<List<U>>() in par_map() constant122 resultPipe.put(endOfStreamMarker) in par_map()135 if (next != endOfStreamMarker) { in par_map()