code: def stop(self):
          
          self._stopped = True
          for result in self._results:
              result._set_result(Failure(ReactorStopped()))
docs: Indicate no more results will get pushed into EventualResults, since
          the reactor has stopped.
  
          This should be called in the reactor thread.