OpenStreamTask

@Singleton
class OpenStreamTask(destinationWriter: DestinationWriter, syncManager: SyncManager, openStreamQueue: MessageQueue<DestinationStream>) : Task

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>)

Properties

Link copied to clipboard

Functions

Link copied to clipboard
open suspend override fun execute()