We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 6bd264e commit e726e24Copy full SHA for e726e24
databroker/src/broker.rs
@@ -1673,7 +1673,10 @@ impl AuthorizedAccess<'_, '_> {
1673
let stream = BroadcastStream::new(receiver).filter_map(move |result| match result {
1674
Ok(message) => Some(message),
1675
Err(err) => {
1676
- warn!("Slow subscriber with capacity {} lagged and missed signal updates: {}", channel_capacity, err);
+ warn!(
1677
+ "Slow subscriber with capacity {} lagged and missed signal updates: {}",
1678
+ channel_capacity, err
1679
+ );
1680
None
1681
}
1682
});
0 commit comments