add method

  1. @override
void add(
  1. T value
)
override

Synchronously send the given value to the consumer, without regard to respecting the maximum buffer size. If this is called, the caller must ensure that flushIfNeeded is called frequently enough to prevent excessive buffer growth.

Implementation

@override
void add(T value) {
  _ensureInConsumer();
  _session!.add(value);
}