Source
Stream<WorkerSession> get sessions {
if (!_sessionListened) {
sockets.forEach((x) => _sessionController.addStream(x.sessions));
_sessionListened = true;
}
return _sessionController.stream;
}
Stream<WorkerSession> get sessions {
if (!_sessionListened) {
sockets.forEach((x) => _sessionController.addStream(x.sessions));
_sessionListened = true;
}
return _sessionController.stream;
}