Example of using Ably's Batch mode with Laravel

AblyBatchBroadcaster.php

<?php

namespace App\Broadcasting;

use Illuminate\Broadcasting\Broadcasters\AblyBroadcaster;

class AblyBatchBroadcaster extends AblyBroadcaster
{
    private $batch = [];

    public function broadcast(array $channels, $event, array $payload = [])
    {
        foreach ($this->formatChannels($channels) as $channel) {
            if (!isset($this->batch[$channel])) {
                $this->batch[$channel] = [];
            }

            $this->batch[$channel][] = [
                'name' => $event,
                'data' => $payload
            ];
        }
    }

    public function handle()
    {
        $batch = [];

        foreach ($this->batch as $channel => $messages)
        {
            array_push($batch, [
                'channels' => $channel,
                'messages' => $messages,
            ]);
        }

        $json = json_encode($batch);
        $this->batch = [];
        return $this->ably->post('/messages', [], $json);
    }
}

example.php

<?php

/*
 * Example Usage, as opposed to firing broadcast() on each of these
 * our method sends them all as one API request to Ably.
 */

batchBroadcast([
  new ShouldBroadcastImplementationA(),
  new ShouldBroadcastImplementationB(),
  new ShouldBroadcastImplementationC()
]);

helpers.php

<?php

if (!function_exists('batchBroadcast')) {
    function batchBroadcast(array $events) {
        $batchBroadcaster = new \App\Broadcasting\AblyBatchBroadcaster(
            new Ably\AblyRest(env('ABLY_KEY'))
        );

        foreach ($events as $event) {
            $event = new \Illuminate\Broadcasting\BroadcastEvent($event);
            $event->handle($batchBroadcaster);
        }

        return $batchBroadcaster->handle();
    }
}