stream property

@override Stream<Measurement>? get stream

The stream of Measurement objects for this StreamProbe. Must be implemented by sub-classes.

Implementation

@override
Stream<Measurement>? get stream => (deviceManager.isConnected)
    ? deviceManager.manager!.eSenseEvents
          .where((event) => event.runtimeType == ButtonEventChanged)
          .map(
            (event) => Measurement.fromData(
              ESenseButton(
                deviceName: deviceManager.manager!.deviceName,
                pressed: (event as ButtonEventChanged).pressed,
              ),
            ),
          )
          .asBroadcastStream()
    : null;