Lines Matching refs:remove

170         self.host_futures.remove(&id).unwrap()  in future_take()
179 self.host_streams.remove(&id).unwrap() in stream_take()
326 test_property(store, |s| s.guest_pending_async_calls_ready.remove(&i)).await, in host_caller_cmd()
339 let future = store.with(|mut s| s.get().host_futures.remove(&i).unwrap()); in host_caller_cmd()
350 let stream = store.with(|mut s| s.get().host_streams.remove(&i).unwrap()); in host_caller_cmd()
366 .remove(&i) in host_callee_cmd()
373 test_property(store, |s| s.host_pending_async_calls_cancelled.remove(&i)).await, in host_callee_cmd()
416 store.with(|mut s| match s.get().host_futures.remove(&id) { in future_or_stream_cmd()
419 let (mut state, _weak) = s.get().host_future_consumers.remove(&id).unwrap(); in future_or_stream_cmd()
461 let (state, weak) = s.get().host_future_producers.remove(&id).unwrap(); in future_or_stream_cmd()
471 let future = data.host_futures.remove(&id).unwrap(); in future_or_stream_cmd()
488 let (state, _) = s.get().host_future_consumers.remove(&id).unwrap(); in future_or_stream_cmd()
529 .remove(&payload.future) in future_or_stream_cmd()
538 let (state, weak) = s.get().host_future_producers.remove(&id).unwrap(); in future_or_stream_cmd()
543 let (state, weak) = s.get().host_future_producers.remove(&id).unwrap(); in future_or_stream_cmd()
563 store.with(|mut s| match s.get().host_streams.remove(&id) { in future_or_stream_cmd()
566 let (mut state, _weak) = s.get().host_stream_consumers.remove(&id).unwrap(); in future_or_stream_cmd()
572 let (mut state, _weak) = s.get().host_stream_producers.remove(&id).unwrap(); in future_or_stream_cmd()
790 let future = data.host_futures.remove(&id).unwrap(); in ensure_future_reading()
819 let stream = data.host_streams.remove(&id).unwrap(); in ensure_stream_reading()