reactor-core/src/main/java/reactor/core/publisher/Flux.java
public final <E extends Subscriber<? super T>> E subscribeWith(E subscriber) {
		subscribe(subscriber);
		return subscriber;
	}
public final <E extends Subscriber<? super T>> E subscribeWith(E subscriber) {
		subscribe(subscriber);
		return subscriber;
	}
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}