code: private void send(T value)
    {
      for (SubscriberNode sub : _subscribers) {
        sub.next(value);
      }
      
      long seq = _sequence++;
      int size = _consumers.size();
      
      if (size > 0) {
        int index = (int) (seq % size);
        
        _consumers.get(index).next(value);
      }
    }
docs: /*
  private boolean pendingSend(T value, Result<Void> result)
  {
  if (_init == StateInit.INIT) {
  return false;
  }
  
  _pendingInit.add(()->send(value, result));
  
  return true;
  }