212         State::with(|s| s.future_readers.remove(&id).unwrap())  in future_take()
221         State::with(|s| s.stream_readers.remove(&id).unwrap())  in stream_take()
289                         .remove(&i)  in run()
297                     State::test_property(|s| s.async_pending_exports_cancelled.remove(&i)).await,  in run()
322                         .remove(&i)  in run()
330                     State::test_property(|s| s.async_pending_imports_ready.remove(&i)).await,  in run()
352                 let reader = State::with(|s| s.future_readers.remove(&id).unwrap());  in run()
356                 let _ = State::with(|s| s.future_readers.remove(&id).unwrap());  in run()
359                 let writer = State::with(|s| s.future_writers.remove(&payload.future).unwrap());  in run()
363                 let reader = State::with(|s| s.future_readers.remove(&payload.future).unwrap());  in run()
367                 let writer = State::with(|s| s.future_writers.remove(&id).unwrap());  in run()
376                 let writer = State::with(|s| s.future_writers.remove(&payload.future).unwrap());  in run()
433                 let reader = State::with(|s| s.future_readers.remove(&id).unwrap());  in run()
486                         .remove(&id)  in run()
499                         .remove(&id)  in run()
511                     State::test_property(|s| match s.future_writes_completed.remove(&id) {  in run()
522                     State::test_property(|s| match s.future_writes_completed.remove(&id) {  in run()
534                         match s.future_reads_completed.remove(&payload.future) {  in run()
565                 let reader = State::with(|s| s.stream_readers.remove(&id).unwrap());  in run()
569                 let _ = State::with(|s| s.stream_readers.remove(&id).unwrap());  in run()
572                 let _ = State::with(|s| s.stream_writers.remove(&id).unwrap());  in run()
619                 let mut writer = State::with(|s| s.stream_writers.remove(&payload.stream).unwrap());  in run()
634                         let _ = s.stream_write_cancel_signals.remove(&payload.stream);  in run()
679                 let mut reader = State::with(|s| s.stream_readers.remove(&payload.stream).unwrap());  in run()
692                         let _ = s.stream_read_cancel_signals.remove(&payload.stream);  in run()
738                         .remove(&id)  in run()
751                         .remove(&id)  in run()
764                         match s.stream_writes_completed.remove(&payload.stream) {  in run()
781                         match s.stream_writes_completed.remove(&payload.stream) {  in run()
798                         match s.stream_reads_completed.remove(&payload.stream) {  in run()
815                         match s.stream_reads_completed.remove(&id) {  in run()