sendLogEvents method

@override Stream<void> sendLogEvents(List<LogEntry> logEntries, Map<String, String> userProperties)

Implementation

@override
Stream<void> sendLogEvents(
    List<LogEntry> logEntries, Map<String, String> userProperties) {
  final cancelToken = CancelToken();
  final streamController = StreamController<void>(onCancel: () {
    cancelToken.cancel();
  });
  streamController.onListen = () {
    sendLogEventsWithDio(logEntries, userProperties, cancelToken).then((val) {
      if (!streamController.isClosed) {
        streamController.add(null);
        streamController.close();
      }
    }).catchError((dynamic err, StackTrace stackTrace) {
      var message = err.runtimeType.toString();
      if (err is DioException) {
        if (err.response != null) {
          message = 'response:${err.response!.data}';
        }
        _logger.warning(
            'Error while sending logs. $message', err, stackTrace);
        if (!streamController.isClosed) {
          streamController.addError(err, stackTrace);
          streamController.close();
        }
      }
    });
  };
  return streamController.stream;
}