stream property

@override Stream<Measurement> stream

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

Implementation

@override
Stream<Measurement> get stream => _stream ??= ar
    .FlutterActivityRecognition.instance.activityStream
    .where((event) => event.type != ar.ActivityType.UNKNOWN)
    .where((event) => event.confidence != ar.ActivityConfidence.LOW)
    .map((activity) => Measurement.fromData(Activity.fromActivity(activity)))
    .asBroadcastStream();