Skip to content

Commit 79e1de6

Browse files
committed
increase capacity for high priority track messages
1 parent 61368b0 commit 79e1de6

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

pulsebeam/src/participant.rs

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -421,8 +421,10 @@ impl ParticipantActor {
421421
});
422422

423423
let track_actor = track::TrackActor::new(ctx.handle.clone(), track_meta.clone());
424-
let (track_handle, join_handle) =
425-
actor::spawn(track_actor, actor::RunnerConfig::default().with_lo(1024));
424+
let (track_handle, join_handle) = actor::spawn(
425+
track_actor,
426+
actor::RunnerConfig::default().with_lo(1024).with_hi(1024),
427+
);
426428

427429
self.track_tasks.push(join_handle);
428430

0 commit comments

Comments
 (0)