async fn process_stream(
    handle: &mut BidiHandle,
    stream: TcpStream,
    irq: Arc<Notify>
)