crates/rust-analyzer/src/op_queue.rs

   1 //! Bookkeeping to make sure only one long-running operation is being executed
   2 //! at a time.
   3
   4 pub(crate) struct OpQueue<Output> {
   5     op_requested: bool,
   6     op_in_progress: bool,
   7     last_op_result: Output,
   8 }
   9
  10 impl<Output: Default> Default for OpQueue<Output> {
  11     fn default() -> Self {
  12         Self { op_requested: false, op_in_progress: false, last_op_result: Default::default() }
  13     }
  14 }
  15
  16 impl<Output> OpQueue<Output> {
  17     pub(crate) fn request_op(&mut self) {
  18         self.op_requested = true;
  19     }
  20     pub(crate) fn should_start_op(&mut self) -> bool {
  21         if self.op_in_progress {
  22             return false;
  23         }
  24         self.op_in_progress = self.op_requested;
  25         self.op_requested = false;
  26         self.op_in_progress
  27     }
  28     pub(crate) fn op_completed(&mut self, result: Output) {
  29         assert!(self.op_in_progress);
  30         self.op_in_progress = false;
  31         self.last_op_result = result;
  32     }
  33
  34     pub(crate) fn last_op_result(&self) -> &Output {
  35         &self.last_op_result
  36     }
  37     pub(crate) fn op_in_progress(&self) -> bool {
  38         self.op_in_progress
  39     }
  40     pub(crate) fn op_requested(&self) -> bool {
  41         self.op_requested
  42     }
  43 }