stream property

@override Stream<Datum> stream

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

Implementation

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