bulk-cdk-core-load/io.airbyte.cdk.load.state/SyncManager/allStreamsComplete

allStreamsComplete

suspend fun allStreamsComplete(): Boolean

Whether we received stream complete messages for all streams in the catalog from upstream.