equal
deleted
inserted
replaced
128 * leaf instance of a {@code ForEachTask} will send elements to the same |
128 * leaf instance of a {@code ForEachTask} will send elements to the same |
129 * {@code TerminalSink} reference that is an instance of this class. |
129 * {@code TerminalSink} reference that is an instance of this class. |
130 * |
130 * |
131 * @param <T> the output type of the stream pipeline |
131 * @param <T> the output type of the stream pipeline |
132 */ |
132 */ |
133 static abstract class ForEachOp<T> |
133 abstract static class ForEachOp<T> |
134 implements TerminalOp<T, Void>, TerminalSink<T, Void> { |
134 implements TerminalOp<T, Void>, TerminalSink<T, Void> { |
135 private final boolean ordered; |
135 private final boolean ordered; |
136 |
136 |
137 protected ForEachOp(boolean ordered) { |
137 protected ForEachOp(boolean ordered) { |
138 this.ordered = ordered; |
138 this.ordered = ordered; |