TailEventStream
An event stream library based on tail.
Note: I don't think you should use this library in a real project, but it's great for educational purposes. I use it in workshops only."
Getting started
Install using Composer:
composer require matthiasnoback/tail-event-stream
Usage
Adding messages to the stream:
use TailEventStream\Producer;
$streamFilePath = __DIR__ . '/var/stream.txt';
$producer = new Producer($streamFilePath);
$producer->produce('hello_world', ['Hello' => 'World!']);
The stream.txt file contains one message per line:
{"messageType":"hello_world","data":{"Hello":"World!"}}
Using tail -f a consumer can read each message from the stream, and it will keep consuming messages until you quit the process:
use TailEventStream\Consumer;
$streamFilePath = __DIR__ . '/var/stream.txt';
$consumer = new Consumer($streamFilePath);
$consumer->consume(function (string $messageType, array $data) {
// $messageType will be 'hello_world'
// $data will be ['Hello' => 'World!']
});
consume() accepts a second argument, which is the index (or line) at which to start.
753 Dec 30, 2022
1.9k Jan 6, 2023
105 Dec 5, 2022
6 May 10, 2021
7 Nov 23, 2022
53 Sep 3, 2022
19 Feb 20, 2022
13 Mar 2, 2022
131 Dec 31, 2022
34 Sep 6, 2022
1.5k Dec 29, 2022
0 Dec 28, 2021
299 Nov 29, 2022
2 Dec 7, 2021
5 Sep 23, 2022
3.6k Dec 27, 2022
44 Jan 1, 2023
4 Dec 30, 2022
89 Nov 28, 2022