PHP code example of clue / reactphp-eventsource

    
        
<?php
require_once('vendor/autoload.php');

/* Start to develop here. Best regards https://php-download.com/ */

    

clue / reactphp-eventsource example snippets

$es = new Clue\React\EventSource\EventSource('https://example.com/stream.php');

$es->on('message', function (Clue\React\EventSource\MessageEvent $message) {
    $json = json_decode($message->data);
    echo $json->name . ': ' . $json->message . PHP_EOL;
});

$es = new Clue\React\EventSource\EventSource('https://example.com/stream.php');

$connector = new React\Socket\Connector([
    'dns' => '127.0.0.1',
    'tcp' => [
        'bindto' => '192.168.10.1:0'
    ],
    'tls' => [
        'verify_peer' => false,
        'verify_peer_name' => false
    ]
]);
$browser = new React\Http\Browser($connector);

$es = new Clue\React\EventSource\EventSource('https://example.com/stream.php', $browser);

$es->on('message', function (Clue\React\EventSource\MessageEvent $message) {
    // $json = json_decode($message->data);
    var_dump($message);
});

$es->on('message', function (Clue\React\EventSource\MessageEvent $message) {
    $json = json_decode($message->data);
    echo "{$json->name} is {$json->age} years old" . PHP_EOL;
});

$es->on('join', function (Clue\React\EventSource\MessageEvent $message) {
    echo $message->data . ' joined' . PHP_EOL;
});

$es->on('chat', function (Clue\React\EventSource\MessageEvent $message) {
    echo 'Message: ' . $message->data . PHP_EOL;
});

$es->on('leave', function (Clue\React\EventSource\MessageEvent $message) {
    echo $message->data . ' left' . PHP_EOL;
});

$es->on('open', function () {
    echo 'Connection opened' . PHP_EOL;
});

$es->on('error', function (Exception $e) {
    echo 'Error: ' . $e->getMessage() . PHP_EOL;
});

$es->on('error', function (Exception $e) use ($es) {
    if ($es->readyState === Clue\React\EventSource\EventSource::CLOSED) {
        echo 'Permanent error: ' . $e->getMessage() . PHP_EOL;
    } else {
        echo 'Temporary error: ' . $e->getMessage() . PHP_EOL;
    }
});

assert($message->data === 'hello');

$json = json_decode($message->data);
assert($json->message === 'hello');

assert($message->data === 'hello');
assert($message->lastEventId === '1');

assert($message->data === 'Alice');
assert($message->type === 'join');

$browser = new React\Http\Browser();

$response = await($browser->requestStreaming(
    'POST',
    'https://api.example.com/v1/messages',
    $headers,
    $body
));
assert($response instanceof Psr\Http\Message\ResponseInterface);

$stream = $response->getBody();
assert($stream instanceof React\Stream\ReadableStreamInterface);

$sse = new Clue\React\EventSource\SseDecoder($stream);
$sse->on('data', function (Clue\React\EventSource\MessageEvent $message) {
    $data = json_decode($message->data);

    if ($data?->type === 'content_block_delta') {
        echo $data->delta->text;
    }
});

$sse = new Clue\React\EventSource\SseDecoder($stream);

$sse = new Clue\React\EventSource\SseDecoder($stream, $lastEventId);

$sse->on('data', function (Clue\React\EventSource\MessageEvent $message) {
    $data = json_decode($message->data);
    echo "{$data->name} is {$data->age} years old" . PHP_EOL;
});

$sse->on('close', function () use ($sse) {
    printf(
        'Reconnect in %.1f seconds with last event ID %s' . PHP_EOL,
        $sse->lastRetryTime ?? 3.0,
        $sse->lastEventId
    );
});

$sse->on('error', function (Exception $error) {
    // an error occurred, stream will close next
});

$sse->on('end', function () {
    // stream successfully ended, stream will close next
});

$sse->on('close', function () {
    // stream closed
    // possibly after an "end" event or due to an "error" event
});

$sse->close();

$map = new ThroughStream(fn (MessageEvent $message) => $message->data);
$sse->pipe($map)->pipe($logger);