reactor-core/src/main/java/reactor/core/publisher/Flux.java
public final Flux<T> takeLast(int n) {
		if(n == 1){
			return onAssembly(new FluxTakeLastOne<>(this));
		}
		return onAssembly(new FluxTakeLast<>(this, n));
	}
public final Flux<T> takeLast(int n) {
		if(n == 1){
			return onAssembly(new FluxTakeLastOne<>(this));
		}
		return onAssembly(new FluxTakeLast<>(this, n));
	}
Emit the last N values this {@link Flux} emitted before its completion.

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

@param n the number of items from this {@link Flux} to retain and emit on onComplete

@return a terminating {@link Flux} sub-sequence