reactor-core/src/main/java/reactor/core/publisher/ConnectableFlux.java
public final Disposable connect() {
		final Disposable[] out = { null };
		connect(r -> out[0] = r);
		return out[0];
	}
public final Disposable connect() {
		final Disposable[] out = { null };
		connect(r -> out[0] = r);
		return out[0];
	}
Connect this {@link ConnectableFlux} to its source and return a {@link Runnable} that
can be used for disconnecting.
@return the {@link Disposable} that allows disconnecting the connection after.