code: public final <E extends Subscriber<? super T>> E subscribeWith(E subscriber) {
  		subscribe(subscriber);
  		return subscriber;
  	}
docs: Subscribe the given {@link Subscriber} to this {@link Flux} and return said
  {@link Subscriber} (eg. a {@link FluxProcessor}).
  
  <blockquote><pre>
  {@code flux.subscribeWith(WorkQueueProcessor.create()).subscribe() }
  </pre></blockquote>
  
  If you need more control over backpressure and the request, use a {@link BaseSubscriber}.
  
  @param subscriber the {@link Subscriber} to subscribe with and return
  @param <E> the reified type from the input/output subscriber
  
  @return the passed {@link Subscriber}