Unboxed whatever I coul

orchid-base/src/reqnot.rs

@@ -318,10 +318,10 @@ pub async fn io_comm<Req: 'static, Not: 'static>(
 	);
 	{
 		let mut shared = pin!(stream_select!(
-			Box::pin(input_stream) as Pin<Box<dyn Stream<Item = Event>>>,
-			Box::pin(onsub.map(Event::Sub)) as Pin<Box<dyn Stream<Item = Event>>>,
-			Box::pin(fork_stream.as_mut()) as Pin<Box<dyn Stream<Item = Event>>>,
-			Box::pin(onexit.map(|()| Event::Exit)) as Pin<Box<dyn Stream<Item = Event>>>,
+			pin!(input_stream) as Pin<&mut dyn Stream<Item = Event>>,
+			onsub.map(Event::Sub),
+			fork_stream.as_mut(),
+			onexit.map(|()| Event::Exit),
 		));
 		let mut pending_replies = HashMap::new();
 		while let Some(next) = shared.next().await {