equal
deleted
inserted
replaced
161 * |
161 * |
162 * @param ordered if event objects arrive in chronological order to {@code #onEvent(Consumer)} |
162 * @param ordered if event objects arrive in chronological order to {@code #onEvent(Consumer)} |
163 */ |
163 */ |
164 public void setOrdered(boolean ordered); |
164 public void setOrdered(boolean ordered); |
165 |
165 |
166 |
|
167 /** |
166 /** |
168 * Starts processing events in the stream. |
167 * Starts processing events in the stream. |
169 * <p> |
168 * <p> |
170 * All actions will performed on this stream will happen in the current |
169 * All actions will performed on this stream will happen in the current |
171 * thread. |
170 * thread. |