fix: Block the sending of control messages

streamnative / pulsar-rs

Rust Client library for Apache Pulsar

Other

369 stars 121 forks source link

Closed cirias closed 3 months ago

cirias commented 3 months ago

Block and wait on the channel to be not full for sending the control messages. This is for fixing https://github.com/streamnative/pulsar-rs/issues/317