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;