enqueueAll method

void enqueueAll(
  1. Iterable<LangfuseEvent> events
)

多条版本,避免单条 enqueue 多次 schedule timer。

Implementation

void enqueueAll(Iterable<LangfuseEvent> events) {
  if (_closed) return;
  _queue.addAll(events);
  if (_queue.length >= config.flushAt) {
    unawaited(flush());
  } else {
    _scheduleFlush();
  }
}