Laravel Reverb skipping broadcasting events

[shahzeb1]

This is quite strange. I have an Event that ShouldBroadcastNow:

<?php

namespace App\Events;

use App\Models\Run;
use App\Models\Input;
use Illuminate\Broadcasting\InteractsWithSockets;
use Illuminate\Broadcasting\PrivateChannel;
use Illuminate\Contracts\Broadcasting\ShouldBroadcastNow;
use Illuminate\Foundation\Events\Dispatchable;
use Illuminate\Queue\SerializesModels;
use Illuminate\Support\Facades\Log;

class RunStreamed implements ShouldBroadcastNow
{
    use Dispatchable, InteractsWithSockets, SerializesModels;

    // ...constructor and channels cut...

   public function broadcastWith(): array
    {
        $data = [
            'thread_id' => $this->run->thread->id,
            'output_id' => $this->run->output->id,
            'input_id' => $this->input->id,
            'word' => $this->word,
        ];

        Log::info('RunStreamed preparing broadcast data', [
            'data' => $data,
            'timestamp' => microtime(true)
        ]);

        return $data;
    }
}

When I look at my production logs, I see RunStreamed preparing broadcast data logs accurately show each word in the logs. I'd expect each word to be broadcast.

I'm running php artisan reverb:start --debug on production and the logs for that show every few events not show up in the reverb logs. Meaning, every few words aren't broadcast.

I am basically running broadcast() in a loop and maybe that's the problem? I'm not sure.

        // In some worker...
        foreach ($response as $chunk) {
            $word = $chunk->choices[0]->delta->content ?? '';

            if ($word !== null) {
                $event = new RunStreamed($this->run, $this->input, $word);
                broadcast($event);
            }
        }

Are there some Reverb limits that aren't well documented? I Feel like running a broadcast in a loop, regardless of how fast the loop is, shouldn't cause issues.

[shahzeb1]

I've tried:

1. Changing from ShouldBroadcastNow to just ShouldBroadcast
2. Tried chunking words, up to 10 at a time, that still makes Reverb skip broadcasting things