allocator will decide budgeting

Author: lherman-cs

pulsebeam/src/participant/downstream/audio.rs

@@ -65,16 +65,7 @@ impl AudioAllocator {
             return Poll::Pending;
         }
 
-        let mut budget = 10;
         loop {
-            if budget == 0 {
-                // Force a wake so we return immediately after the runtime
-                // polls other tasks (like Video).
-                cx.waker().wake_by_ref();
-                return Poll::Pending;
-            }
-            budget -= 1;
-
             let (track_id, packet) = match self.inputs.poll_next_unpin(cx) {
                 Poll::Ready(Some(val)) => val,
                 Poll::Ready(None) => return Poll::Ready(None), // All inputs closed

pulsebeam/src/participant/downstream/video.rs

@@ -354,17 +354,7 @@ impl Slot {
     }
 
     fn poll_next(&mut self, cx: &mut Context<'_>) -> Poll<Option<RtpPacket>> {
-        // Process a limited number of iterations to ensure fairness
-        let mut budget = 10;
-
         loop {
-            if budget == 0 {
-                // yield now, let others run first.
-                cx.waker().wake_by_ref();
-                return Poll::Pending;
-            }
-            budget -= 1;
-
             if let Some(pkt) = self.switcher.pop() {
                 return Poll::Ready(Some(pkt));
             }