docs: @Synchronized("lock")
      public void disconnect(final ReactiveSeq<T> stream) {
  
        Option<Queue<T>> o = streamToQueue.get(stream);
  
          distributor.removeQueue(streamToQueue.getOrElse(stream, new Queue<>()));
          this.streamToQueue = streamToQueue.remove(stream);
          this.index--;
      }