equal
deleted
inserted
replaced
329 stream.awaitTermination(); |
329 stream.awaitTermination(); |
330 } |
330 } |
331 |
331 |
332 @Override |
332 @Override |
333 public void setReuse(boolean reuse) { |
333 public void setReuse(boolean reuse) { |
334 throw new UnsupportedOperationException("Unordered not implemented yet"); |
334 stream.setReuse(reuse); |
335 } |
335 } |
336 |
336 |
337 @Override |
337 @Override |
338 public void setOrdered(boolean ordered) { |
338 public void setOrdered(boolean ordered) { |
339 stream.setOrdered(ordered); |
339 stream.setOrdered(ordered); |