OpenStreamTask
@Singleton
Consumes DestinationStreams from the openStreamQueue, creates/starts a StreamLoader for each, and registers it with the SyncManager.
Duplicate streams across the entire sync are ignored: start() is called at most once per stream descriptor, even with multiple concurrent workers.
TODO: There's no reason to wait on initialization to start spilling to disk.
Constructors
Link copied to clipboard
constructor(destinationWriter: DestinationWriter, syncManager: SyncManager, openStreamQueue: MessageQueue<DestinationStream>)