registerStream method
Registers a ProcessingStream with this synchronizer.
Implementation
void registerStream(ProcessingStream stream) {
_streams[stream.name] = stream;
_logger.debug('Registered stream: "${stream.name}"');
}
Registers a ProcessingStream with this synchronizer.
void registerStream(ProcessingStream stream) {
_streams[stream.name] = stream;
_logger.debug('Registered stream: "${stream.name}"');
}