Skip to content

Commit 93f889a

Browse files
committed
fix: reset stream metrics batch on flush
1 parent 8948c2b commit 93f889a

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

uplink/src/base/bridge/stream.rs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -109,6 +109,7 @@ impl Stream {
109109
/// Triggers flush and async channel send if not empty
110110
pub async fn flush(&mut self) -> Result<(), Error> {
111111
if !self.is_empty() {
112+
self.metrics.add_batch();
112113
let buf = self.take_buffer();
113114
self.tx.send_async(Box::new(buf)).await?;
114115
}

0 commit comments

Comments
 (0)