fn park(&self) {
        {
            let mut sender = self.sender_task.lock();
            sender.task = None;
            sender.is_parked = true;
        }

        // Send handle over queue
        self.inner.parked_queue.push(Arc::clone(&self.sender_task));

        // Check to make sure we weren't closed after we sent our task on the queue
        let state = decode_state(self.inner.state.load(SeqCst));
        self.maybe_parked.store(state.is_open, Relaxed);
    }
// TODO: Not sure about this one, I modified code to match the futures one, might still be buggy
Not sure about this one, I modified code to match the futures one, might still be buggy
Not sure about this one I modified code to match the futures one might still be buggy
fn park(&self) {
        {
            let mut sender = self.sender_task.lock();
            sender.task = None;
            sender.is_parked = true;
        }
        // Send handle over queue
        self.inner.parked_queue.push(Arc::clone(&self.sender_task));
        // Check to make sure we weren't closed after we sent our task on the queue
        let state = decode_state(self.inner.state.load(SeqCst));
        self.maybe_parked.store(state.is_open, Relaxed);
    }
fn park ( & self ) { { let mut sender = self . sender_task . lock ( ) ; sender . task = None ; sender . is_parked = true ; } // Send handle over queue self . inner . parked_queue . push ( Arc :: clone ( & self . sender_task ) ) ; // Check to make sure we weren't closed after we sent our task on the queue let state = decode_state ( self . inner . state . load ( SeqCst ) ) ; self . maybe_parked . store ( state . is_open , Relaxed ) ; }
TODO: Not sure about this one, I modified code to match the futures one, might still be buggy
TODO : Not sure about this one I modified code to match the futures one might still be buggy
&self
&self