code: final public Flux<IN> forceShutdown() {
  		int t = terminated;
  		if (t != FORCED_SHUTDOWN && TERMINATED.compareAndSet(this, t, FORCED_SHUTDOWN)) {
  			executor.shutdownNow();
  			requestTaskExecutor.shutdownNow();
  		}
  		return drain();
  	}
docs: 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