code: @Override
      public void onNext(final T t) {
  
          Objects.requireNonNull(t);
          counter.added++;
          queue.add(t);
  
  
  
  
  
      }
docs: /* (non-Javadoc)
  @see org.reactivestreams.Subscriber#onNext(java.lang.Object)