code: public final Disposable connect() {
  		final Disposable[] out = { null };
  		connect(r -> out[0] = r);
  		return out[0];
  	}
docs: 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.