remote: Fix formatting (#19438)
This PR fixes some formatting issues from #19398 that slipped past CI, somehow. Release Notes: - N/A
This commit is contained in:
parent
98ecb43b2d
commit
47380001cc
1 changed files with 4 additions and 2 deletions
|
@ -1591,14 +1591,16 @@ impl ChannelClient {
|
||||||
buffer.pop_front();
|
buffer.pop_front();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
if let Some(proto::envelope::Payload::FlushBufferedMessages(_)) = &incoming.payload {
|
if let Some(proto::envelope::Payload::FlushBufferedMessages(_)) =
|
||||||
|
&incoming.payload
|
||||||
|
{
|
||||||
{
|
{
|
||||||
let buffer = this.buffer.lock();
|
let buffer = this.buffer.lock();
|
||||||
for envelope in buffer.iter() {
|
for envelope in buffer.iter() {
|
||||||
this.outgoing_tx.unbounded_send(envelope.clone()).ok();
|
this.outgoing_tx.unbounded_send(envelope.clone()).ok();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
let response = proto::Ack{}.into_envelope(0, Some(incoming.id), None);
|
let response = proto::Ack {}.into_envelope(0, Some(incoming.id), None);
|
||||||
this.send_dynamic(response).ok();
|
this.send_dynamic(response).ok();
|
||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue