onStart method

@override Future<bool> onStart()

Callback when this executor is started. Returns true if successfully started, false otherwise.

Implementation

@override
Future<bool> onStart() async {
  Duration? interval = samplingConfiguration?.interval;
  Duration? duration = samplingConfiguration?.duration;
  if (interval != null && duration != null) {
    timer = Timer.periodic(interval, (Timer t) {
      onSamplingStart();
      _subscription = bufferingStream.listen(onSamplingData,
          onError: onError, onDone: onDone);
      Timer(duration, () async {
        await _subscription?.cancel();
        onSamplingEnd();
        try {
          Measurement? measurement = await getMeasurement();
          if (measurement != null) addMeasurement(measurement);
        } catch (error) {
          addError(error);
        }
      });
    });
  } else {
    warning(
        '$runtimeType - no valid interval and duration found in sampling configuration: $samplingConfiguration. '
        'Is a valid PeriodicSamplingConfiguration provided?');
    return false;
  }
  return true;
}