diff options
Diffstat (limited to 'lib/control/scanner_controller_impl.dart')
-rw-r--r-- | lib/control/scanner_controller_impl.dart | 12 |
1 files changed, 12 insertions, 0 deletions
diff --git a/lib/control/scanner_controller_impl.dart b/lib/control/scanner_controller_impl.dart index 427a3e8..e60aec3 100644 --- a/lib/control/scanner_controller_impl.dart +++ b/lib/control/scanner_controller_impl.dart @@ -9,6 +9,8 @@ abstract class ScannerControllerImpl extends ScannerController { StreamController<ScanStatus>.broadcast(); final StreamController<List<Device>> _deviceContoller = StreamController<List<Device>>.broadcast(); + final StreamController<ScanAvailability> _availabilityStreamController = + StreamController<ScanAvailability>.broadcast(); @override Stream<ScanStatus> get statusStream => _scanStatusController.stream; @@ -16,6 +18,10 @@ abstract class ScannerControllerImpl extends ScannerController { @override Stream<List<Device>> get scanResultsStream => _deviceContoller.stream; + @override + Stream<ScanAvailability> get availabilityStream => + _availabilityStreamController.stream; + @protected void setStatus(ScanStatus newStatus) { if (_scanStatusController.isClosed) return; @@ -30,9 +36,15 @@ abstract class ScannerControllerImpl extends ScannerController { _deviceContoller.add(devices); } + @protected + void setAvailability(ScanAvailability available) { + _availabilityStreamController.add(available); + } + @override void dispose() { _scanStatusController.close(); _deviceContoller.close(); + _availabilityStreamController.close(); } } |