reactor-core/src/main/java/reactor/core/publisher/Mono.java
public final Flux<T> flux() {
	    if (this instanceof Callable) {
	        if (this instanceof Fuseable.ScalarCallable) {
		        T v;
		        try {
			        v = block();
		        }
		        catch (Throwable t) {
			        return Flux.error(t);
		        }
	            if (v == null) {
	                return Flux.empty();
	            }
	            return Flux.just(v);
	        }
		    @SuppressWarnings("unchecked") Callable<T> thiz = (Callable<T>) this;
		    return Flux.onAssembly(new FluxCallable<>(thiz));
	    }
		return Flux.wrap(this);
	}
public final Flux<T> flux() {
	    if (this instanceof Callable) {
	        if (this instanceof Fuseable.ScalarCallable) {
		        T v;
		        try {
			        v = block();
		        }
		        catch (Throwable t) {
			        return Flux.error(t);
		        }
	            if (v == null) {
	                return Flux.empty();
	            }
	            return Flux.just(v);
	        }
		    @SuppressWarnings("unchecked") Callable<T> thiz = (Callable<T>) this;
		    return Flux.onAssembly(new FluxCallable<>(thiz));
	    }
		return Flux.wrap(this);
	}
public final Flux < T > flux ( ) { if ( this instanceof Callable ) { if ( this instanceof Fuseable . ScalarCallable ) { T v ; try { v = block ( ) ; } catch ( Throwable t ) { return Flux . error ( t ) ; } if ( v == null ) { return Flux . empty ( ) ; } return Flux . just ( v ) ; } @ SuppressWarnings ( "unchecked" ) Callable < T > thiz = ( Callable < T > ) this ; return Flux . onAssembly ( new FluxCallable <> ( thiz ) ) ; } return Flux . wrap ( this ) ; }
Convert this {@link Mono} to a {@link Flux}

@return a {@link Flux} variant of this {@link Mono}
Convert this { @link Mono } to a { @link Flux }