equal
deleted
inserted
replaced
201 /** |
201 /** |
202 * Specifies end time of the event stream. |
202 * Specifies end time of the event stream. |
203 * <p> |
203 * <p> |
204 * The end time must be set before the stream is started. |
204 * The end time must be set before the stream is started. |
205 * <p> |
205 * <p> |
206 * When the end time is reached the stream is terminated. |
206 * When the end time is reached the stream is closed. |
207 * |
207 * |
208 * @param endTime the end time, not {@code null} |
208 * @param endTime the end time, not {@code null} |
209 * |
209 * |
210 * @throws IllegalStateException if the stream has already been started |
210 * @throws IllegalStateException if the stream has already been started |
211 */ |
211 */ |
212 public void setEndTime(Instant endTime); |
212 public void setEndTime(Instant endTime); |
213 |
|
214 |
213 |
215 /** |
214 /** |
216 * Start processing events in the stream. |
215 * Start processing events in the stream. |
217 * <p> |
216 * <p> |
218 * All actions performed on this stream will happen in the current thread. |
217 * All actions performed on this stream will happen in the current thread. |