Category "tokio"

how to store a closure to map and call it in another thread?

I just try to write a consumer for rocketmq with rust, and have a PushConsumer like below: pub struct PushConsumer { consumer: Consumer, handler_map: Ha

how to store a closure to map and call it in another thread?

I just try to write a consumer for rocketmq with rust, and have a PushConsumer like below: pub struct PushConsumer { consumer: Consumer, handler_map: Ha

Other Categories