Lines Matching refs:insert
185 State::with(|s| s.async_pending_exports_ready.insert(id, tx)); in async_pending()
197 s.async_pending_exports_cancelled.insert(self.0); in async_pending()
216 let prev = State::with(|s| s.future_readers.insert(id, f)); in future_receive()
225 let prev = State::with(|s| s.stream_readers.insert(id, f)); in stream_receive()
307 s.async_pending_imports_in_progress.insert(i, cancel_tx); in run()
313 State::with(|s| s.async_pending_imports_ready.insert(i)); in run()
338 let prev = s.future_writers.insert(id, writer); in run()
340 let prev = s.future_readers.insert(id, reader); in run()
347 let prev = s.future_readers.insert(id, reader); in run()
388 s.future_writes_completed.insert(payload.future, true); in run()
391 s.future_writes_completed.insert(payload.future, false); in run()
394 let prev = s.future_writers.insert(payload.future, writer); in run()
400 let prev = s.future_write_cancel_signals.insert(payload.future, tx); in run()
444 let prev = s.future_reads_completed.insert(id, result); in run()
448 let prev = s.future_readers.insert(id, reader); in run()
454 let prev = s.future_read_cancel_signals.insert(id, tx); in run()
551 let prev = s.stream_writers.insert(id, writer); in run()
553 let prev = s.stream_readers.insert(id, reader); in run()
560 let prev = s.stream_readers.insert(id, reader); in run()
622 let prev = s.stream_write_cancel_signals.insert(payload.stream, tx); in run()
638 .insert(payload.stream, Ok((n, remaining))); in run()
642 .insert(payload.stream, Err((0, remaining))); in run()
646 let prev = s.stream_writers.insert(payload.stream, writer); in run()
682 let prev = s.stream_read_cancel_signals.insert(payload.stream, tx); in run()
695 s.stream_reads_completed.insert(payload.stream, Some(buf)); in run()
699 s.stream_reads_completed.insert(payload.stream, None); in run()
703 let prev = s.stream_readers.insert(payload.stream, reader); in run()