sendLogEvents method

Implementation

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