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; }