add method

void add(T value)

Sends value to all current subscribers or the initial replay buffer.

Implementation

void add(T value) {
  if (_isClosed) {
    return;
  }
  if (_subscribers.isEmpty && !_hasSubscribed) {
    if (_replay.length == capacity) {
      _replay.removeFirst();
    }
    _replay.addLast(value);
    return;
  }
  for (final _HubSubscriber<T> subscriber in _subscribers.toList()) {
    subscriber.add(value);
  }
}