Tiny test fixes.

proto/src/core/channel.rs

@@ -285,7 +285,6 @@ mod tests {
         let stream = TcpStream::connect(address).await.unwrap();
         let channel = Channel::<u32, u32>::new(stream);
 
-        // Send a message, then close the channel.
         let (tx, rx) = oneshot::channel::<()>();
 
         // Send one message then wait for a reply. If we did not wait, we might

proto/tests/connect.rs

@@ -57,11 +57,11 @@ async fn integration_check_user_status() {
 
     let (request_tx, mut request_rx) = mpsc::channel(1);
 
-    let outbound = Box::pin(async_stream::stream! {
+    let outbound = async_stream::stream! {
       while let Some(request) = request_rx.recv().await {
         yield request;
       }
-    });
+    };
 
     let inbound = client.run(outbound);
     tokio::pin!(inbound);