final public Flux<IN> forceShutdown() {
		int t = terminated;
		if (t != FORCED_SHUTDOWN && TERMINATED.compareAndSet(this, t, FORCED_SHUTDOWN)) {
			executor.shutdownNow();
			requestTaskExecutor.shutdownNow();
		}
		return drain();
	}
final public Flux<IN> forceShutdown() {
		int t = terminated;
		if (t != FORCED_SHUTDOWN && TERMINATED.compareAndSet(this, t, FORCED_SHUTDOWN)) {
			executor.shutdownNow();
			requestTaskExecutor.shutdownNow();
		}
		return drain();
	}
final public Flux < IN > forceShutdown ( ) { int t = terminated ; if ( t != FORCED_SHUTDOWN && TERMINATED . compareAndSet ( this , t , FORCED_SHUTDOWN ) ) { executor . shutdownNow ( ) ; requestTaskExecutor . shutdownNow ( ) ; } return drain ( ) ; }
Shutdown this {@code Processor}, forcibly halting any work currently executing and discarding any tasks that have
not yet been executed.
@return a Flux instance with the remaining undelivered values
Shutdown this {