We have credit to send a message.
| 191 | |
| 192 | // We have credit to send a message. |
| 193 | void Sender::on_sendable(proton::sender &sender) { |
| 194 | if (queue_) { |
| 195 | auto credit = sender.credit(); |
| 196 | queue_->add([=]{queue_->flow(this, credit);}); |
| 197 | } else { |
| 198 | pending_credit_ = sender.credit(); |
| 199 | } |
| 200 | } |
| 201 | |
| 202 | void Sender::on_sender_close(proton::sender &sender) { |
| 203 | if (queue_) { |