put method

void put(
  1. StreamEvent event
)

Implementation

void put(StreamEvent event) {
  if (_closed) return;
  if (_waiters.isNotEmpty) {
    _waiters.removeAt(0).complete(event);
  } else {
    _items.add(event);
  }
}