Interface Synchronizer
- All Superinterfaces:
AutoCloseable,Closeable
Interface for an FDv2 data source synchronizer that produces a stream of results.
The orchestrator calls next() repeatedly. Each call returns a Future
that completes with the next result (change set or status). After SHUTDOWN or TERMINAL_ERROR,
no further calls to next() should be made. INTERRUPTED and GOODBYE allow the orchestrator to
switch synchronizers or retry.
Only one outstanding next() call is expected at a time.
When Closeable.close() is called, the implementation must complete any outstanding
next() future so that the orchestrator is not blocked indefinitely.
- See Also:
-
Method Summary
-
Method Details
-
next
Future<FDv2SourceResult> next()Request the next result from the stream.Complete the returned future when the next result is available. The caller may call next() again for the next result. Only one outstanding next() call is expected at a time.
- Returns:
- a Future that completes with the next result (change set or status)
-