reactor-core/src/main/java/reactor/core/publisher/Flux.java
@Nullable
	public final T blockLast(Duration timeout) {
		BlockingLastSubscriber<T> subscriber = new BlockingLastSubscriber<>();
		Operators.onLastAssembly(this).subscribe(Operators.toCoreSubscriber(subscriber));
		return subscriber.blockingGet(timeout.toMillis(), TimeUnit.MILLISECONDS);
	}
@Nullable
	public final T blockLast(Duration timeout) {
		BlockingLastSubscriber<T> subscriber = new BlockingLastSubscriber<>();
		Operators.onLastAssembly(this).subscribe(Operators.toCoreSubscriber(subscriber));
		return subscriber.blockingGet(timeout.toMillis(), TimeUnit.MILLISECONDS);
	}
@ Nullable public final T blockLast ( Duration timeout ) { BlockingLastSubscriber < T > subscriber = new BlockingLastSubscriber <> ( ) ; Operators . onLastAssembly ( this ) . subscribe ( Operators . toCoreSubscriber ( subscriber ) ) ; return subscriber . blockingGet ( timeout . toMillis ( ) , TimeUnit . MILLISECONDS ) ; }
Subscribe to this {@link Flux} and <strong>block</strong> until the upstream
signals its last value, completes or a timeout expires. Returns that value,
or null if the Flux completes empty. In case the Flux errors, the original
exception is thrown (wrapped in a {@link RuntimeException} if it was a checked
exception). If the provided timeout expires,a {@link RuntimeException} is thrown.
<p>
Note that each blockLast() will trigger a new subscription: in other words,
the result might miss signal from hot publishers.

<p>
<img class="marble" src="doc-files/marbles/blockLastWithTimeout.svg" alt="">

@param timeout maximum time period to wait for before raising a {@link RuntimeException}
@return the last value or null
Subscribe to this { @link Flux } and <strong > block< / strong > until the upstream signals its last value completes or a timeout expires . Returns that value or null if the Flux completes empty . In case the Flux errors the original exception is thrown ( wrapped in a { @link RuntimeException } if it was a checked exception ) . If the provided timeout expires a { @link RuntimeException } is thrown . <p > Note that each blockLast () will trigger a new subscription : in other words the result might miss signal from hot publishers .