Skip to content

Commit e59ebcb

Browse files
committed
fix: add missing live stream broadcaster drop
1 parent 6d9cf45 commit e59ebcb

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

src/event_scanner.rs

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -463,6 +463,9 @@ impl<N: Network> ConnectedEventScanner<N> {
463463
}
464464
}
465465

466+
// TODO: create helper function for appropriately spawning and cleaning up log consumers
467+
drop(live_tx);
468+
466469
// This serves two purposes:
467470
// 1. Ensure that all log consumers finish streaming live events before the scanner is
468471
// stopped

0 commit comments

Comments
 (0)