data property

Stream<DataPoint> get data

The stream of all sampled data points.

Data points in the data stream are transformed in the following order:

1. privacy schema as specified in the privacySchemaName
2. preferred data format as specified by dataFormat in the SmartphoneDeployment.dataEndPoint
3. any custom transformer provided

This is a broadcast stream and supports multiple subscribers.

Implementation

Stream<DataPoint> get data => _executor!.data
    .map((dataPoint) => dataPoint
      ..data = _transformer(TransformerSchemaRegistry()
          .lookup(deployment?.dataEndPoint?.dataFormat ?? NameSpace.CARP)!
          .transform(TransformerSchemaRegistry()
              .lookup(privacySchemaName)!
              .transform(dataPoint.data as Datum))))
    .map((dataPoint) =>
        dataPoint..carpHeader.dataFormat = dataPoint.data!.format);