code: @Override
      public void cancelAllScheduledForActor() {
  	final Set<ActionContext<T>> toCancel;
  	synchronized (contexts) {
  	    toCancel = new HashSet<>(contexts);
  	    contexts.clear();
  	}
  
  	// Cancel all
  	toCancel.forEach(cxt -> {
  	    if (!cxt.isDone()) {
  		cxt.cancel();
  	    }
  	});
      }
docs: Cancel all tasks scheduled to the current engine for the actor by this scheduler.