fix: Actually flush destinations before selecting new events
This commit is contained in:
parent
5e3174493d
commit
82bd0c8e15
1 changed files with 3 additions and 0 deletions
|
|
@ -203,6 +203,9 @@ impl Service {
|
||||||
futures: &mut SendingFutures<'a>,
|
futures: &mut SendingFutures<'a>,
|
||||||
statuses: &mut CurTransactionStatus,
|
statuses: &mut CurTransactionStatus,
|
||||||
) {
|
) {
|
||||||
|
if msg.event == SendingEvent::Flush {
|
||||||
|
statuses.remove(&msg.dest);
|
||||||
|
}
|
||||||
let iv = vec![(msg.queue_id, msg.event)];
|
let iv = vec![(msg.queue_id, msg.event)];
|
||||||
if let Ok(Some(events)) = self.select_events(&msg.dest, iv, statuses).await {
|
if let Ok(Some(events)) = self.select_events(&msg.dest, iv, statuses).await {
|
||||||
if !events.is_empty() {
|
if !events.is_empty() {
|
||||||
|
|
|
||||||
Loading…
Add table
Reference in a new issue