@Override
    public void onNext(final T t) {

        Objects.requireNonNull(t);
        counter.added++;
        queue.add(t);





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