diff --git a/rt/src/coordinator.rs b/rt/src/coordinator.rs index 656a052e..58098d52 100644 --- a/rt/src/coordinator.rs +++ b/rt/src/coordinator.rs @@ -217,7 +217,7 @@ impl Coordinator { fn check_process_signals(&mut self, signal_received: &mut bool) -> Result<(), rt::Error> { let timing = trace::start(&self.trace_log); let waker = task::Waker::noop(); - let mut ctx = task::Context::from_waker(&waker); + let mut ctx = task::Context::from_waker(waker); loop { match self.signals.poll_signal(&mut ctx) { Poll::Ready(Some(Ok(info))) => { diff --git a/rt/src/test.rs b/rt/src/test.rs index f68407f6..698d1dcf 100644 --- a/rt/src/test.rs +++ b/rt/src/test.rs @@ -599,7 +599,7 @@ where Fut: Future + ?Sized, { let waker = task::Waker::noop(); - let mut ctx = task::Context::from_waker(&waker); + let mut ctx = task::Context::from_waker(waker); Future::poll(future, &mut ctx) } @@ -614,7 +614,7 @@ where I: AsyncIterator + ?Sized, { let waker = task::Waker::noop(); - let mut ctx = task::Context::from_waker(&waker); + let mut ctx = task::Context::from_waker(waker); AsyncIterator::poll_next(iter, &mut ctx) } @@ -632,7 +632,7 @@ where A: Actor + ?Sized, { let waker = task::Waker::noop(); - let mut ctx = task::Context::from_waker(&waker); + let mut ctx = task::Context::from_waker(waker); Actor::try_poll(actor, &mut ctx) } diff --git a/rt/src/trace.rs b/rt/src/trace.rs index 50dbbac6..9bd87b2a 100644 --- a/rt/src/trace.rs +++ b/rt/src/trace.rs @@ -407,7 +407,7 @@ impl TraceLog for Log { impl<'a> TraceLog for &'a SharedLog { fn append(&mut self, substream_id: u64, event: &Event<'_>) -> io::Result<()> { thread_local! { - static BUF: RefCell> = RefCell::new(Vec::new()); + static BUF: RefCell> = const { RefCell::new(Vec::new()) }; } BUF.with(|buf| {