錆びたTokioタスクで無期限に無制限のチャネルを読み取る方法はありますか？

Question

私は.for_each()がトリックを行うと仮定しましたが、チャンネルから最初の（将来の）項目のみを返し、チャンネルが空であれば戻ります。 .for_each()が非Tokio /将来のコンテキストで行うように、タスクのチャネルを無期限に読み取る方法は何ですか？

let tx_origs_reader = rx_chan.for_each(move |tx_orig| { 
    //save receiver side tx to db 
    let mut tx_origs_once = tx_origs_inner.borrow_mut(); 
    tx_origs_once.push(tx_orig.clone()); 
    Ok(()) 
}); 
handle.spawn(tx_origs_reader.then(|err| { 
    println!("This returns after first item without an error {:?}", err); 
    Ok(()) 
})); 

Answer 1

for_eachの処理方法が最善の方法です。動作する必要があります。簡単なテストコードを使ってGitter（感謝！）のtokio-rsの助けを借りて、tx側で問題をデバッグしました。

Rustは非常に高度なので、実際にこの場合はタスクを落とすことを知っていたようです。この問題に基づいてログ出力が実際にrx側にあると思うのは混乱しています。ずっと。