code: public static RuntimeException onRejectedExecution(Throwable original, Context context) {
  		return onRejectedExecution(original, null, null, null, context);
  	}
docs: Return a wrapped {@link RejectedExecutionException} which can be thrown by the
  operator. This exception denotes that an execution was rejected by a
  {@link reactor.core.scheduler.Scheduler}, notably when it was already disposed.
  <p>
  Wrapping is done by calling both {@link Exceptions#bubble(Throwable)} and
  {@link #onOperatorError(Subscription, Throwable, Object, Context)}.
  
  @param original the original execution error
  @param context a context that might hold a local error consumer