1111// RUNNING --> TERMINAL_ERROR
1212// TERMINAL_ERROR --> [*]
1313// RUNNING --> GOODBYE
14- // GOODBYE --> [*]
14+ // GOODBYE --> RUNNING
1515// RUNNING --> CHANGE_SET
1616// CHANGE_SET --> RUNNING
1717// RUNNING --> INTERRUPTED
3434 * ┌─►│ RUNNING │──┐
3535 * │ └─────────────┘ │
3636 * │ │ │ │ │ │
37- * │ │ │ │ │ └──► SHUTDOWN ───► [END]
37+ * │ │ │ │ │ └──► SHUTDOWN ─────────── ► [END]
3838 * │ │ │ │ │
39- * │ │ │ │ └──────► TERMINAL_ERROR ───► [END]
39+ * │ │ │ │ └──────► TERMINAL_ERROR ───── ► [END]
4040 * │ │ │ │
41- * │ │ │ └──────────► GOODBYE ───► [END]
42- * │ │ │
43- * │ │ └──────────────► CHANGE_SET ───┐
44- * │ │ │
45- * │ └──────────────────► INTERRUPTED ──┤
46- * │ │
47- * └──────────────────────────────────────┘
41+ * │ │ │ └──────────► GOODBYE ────────────┐
42+ * │ │ │ │
43+ * │ │ └──────────────► CHANGE_SET ─────────┤
44+ * │ │ │
45+ * │ └──────────────────► INTERRUPTED ──────── ┤
46+ * │ │
47+ * └──────────────────────────────────────────── ┘
4848 */
4949public interface Synchronizer extends Closeable {
5050 /**
@@ -53,7 +53,7 @@ public interface Synchronizer extends Closeable {
5353 * This method is intended to be driven by a single thread, and for there to be a single outstanding call
5454 * at any given time.
5555 * <p>
56- * Once SHUTDOWN, TERMINAL_ERROR, or GOODBYE has been produced, then no further calls to next() should be made.
56+ * Once SHUTDOWN or TERMINAL_ERROR, has been produced, then no further calls to next() should be made.
5757 * @return a future that will complete when the next result is available
5858 */
5959 CompletableFuture <FDv2SourceResult > next ();
0 commit comments