StreamProcessor.addStream

Adds an input stream (which must implement ISuspendable) to the set of streams which are to be throttled. If it is already in the set, nothing happens.

class StreamProcessor(TaskT : Task)
void
addStream

Parameters

s ISuspendable

suspendable input stream to be throttled

Meta