[2.x] Add Examples

Author: WyriHaximus

README.md

@@ -23,39 +23,31 @@ event loop, that will work, but it adds additional overhead when you have more t
 different major contexts. Share this bridge around so that other packages can use them, and only have one instance
 checking for events.
 
-```php
-use React\EventLoop\Factory;
-use ReactParallel\EventLoop\EventLoopBridge;
-
-$loop = Factory::create();
-$eventLoopBridge = new EventLoopBridge($loop);
-
-$loop->run();
-```
-
 ## Channels
 
 Channels often have a stream of messages going over them, as such the bridge will convert them into an observable.
 
 ```php
 use parallel\Channel;
-use React\EventLoop\Factory;
+use React\EventLoop\Loop;
 use ReactParallel\EventLoop\EventLoopBridge;
+use function React\Async\async;
 
-$loop = Factory::create();
-$eventLoopBridge = new EventLoopBridge($loop);
+$eventLoopBridge = new EventLoopBridge();
 
-$channel = new Channel(Channel::Infinite);
-$eventLoopBridge->observe($channel)->subscribe(function (string $message) {
-    echo $message, PHP_EOL;
-});
+Loop::futureTick(async(static function () use ($eventLoopBridge) {
+    /** @var Channel<string> */
+    $channel = new Channel(Channel::Infinite);
 
-$loop->futureTick(function () use ($channel): void {
-    $channel->send('Hello World!');
-    $channel->close();
-});
+    Loop::futureTick(function () use ($channel): void {
+        $channel->send('Hello World!');
+        $channel->close();
+    });
 
-$loop->run();
+    foreach ($eventLoopBridge->observe($channel) as $message) {
+        echo $message, PHP_EOL;
+    }
+}));
 ```
 
 ## Futures
@@ -64,24 +56,20 @@ Where promises are push, futures are pull, as such the event loop will poll and
 available.
 
 ```php
-use parallel\Channel;
-use React\EventLoop\Factory;
+use React\EventLoop\Loop;
 use ReactParallel\EventLoop\EventLoopBridge;
 use function parallel\run;
+use function React\Async\async;
 
-$loop = Factory::create();
-$eventLoopBridge = new EventLoopBridge($loop);
-
-$future = run(function (): string {
-    return 'Hello World!';
-});
+$eventLoopBridge = new EventLoopBridge();
 
-$channel = new Channel(Channel::Infinite);
-$eventLoopBridge->await($future)->then(function (string $message) {
-    echo $message, PHP_EOL;
-});
+Loop::futureTick(async(static function () use ($eventLoopBridge) {
+    $future = run(function (): string {
+        return 'Hello World!';
+    });
 
-$loop->run();
+    echo $eventLoopBridge->await($future), PHP_EOL;
+}));
 ```
 
 ## Metrics
@@ -105,7 +93,7 @@ Please see [CONTRIBUTING](CONTRIBUTING.md) for details.
 
 ## License ##
 
-Copyright 2024 [Cees-Jan Kiewiet](http://wyrihaximus.net/)
+Copyright 2025 [Cees-Jan Kiewiet](http://wyrihaximus.net/)
 
 Permission is hereby granted, free of charge, to any person
 obtaining a copy of this software and associated documentation

examples/channel.php

@@ -0,0 +1,35 @@
+<?php declare(strict_types=1);
+
+use parallel\Channel;
+use React\EventLoop\Loop;
+use ReactParallel\EventLoop\EventLoopBridge;
+use function parallel\run;
+use function React\Async\async;
+
+require_once __DIR__ . '/../vendor/autoload.php';
+
+$eventLoopBridge = new EventLoopBridge();
+/** @var Channel<string> */
+$channel = Channel::make('strings', Channel::Infinite);
+
+
+Loop::futureTick(async(static function () use ($eventLoopBridge, $channel) {
+    echo __LINE__, PHP_EOL;
+    foreach ($eventLoopBridge->observe($channel) as $message) {
+        echo __LINE__, PHP_EOL;
+        echo $message, PHP_EOL;
+        echo __LINE__, PHP_EOL;
+    }
+    echo __LINE__, PHP_EOL;
+}));
+
+Loop::addTimer(1, function () use ($channel): void {
+    run(function () use ($channel): void {
+        echo __LINE__, PHP_EOL;
+        $channel->send('Hello World!');
+        echo __LINE__, PHP_EOL;
+        $channel->close();
+        echo __LINE__, PHP_EOL;
+    });
+});
+

examples/future.php

@@ -0,0 +1,18 @@
+<?php declare(strict_types=1);
+
+use React\EventLoop\Loop;
+use ReactParallel\EventLoop\EventLoopBridge;
+use function parallel\run;
+use function React\Async\async;
+
+require_once __DIR__ . '/../vendor/autoload.php';
+
+$eventLoopBridge = new EventLoopBridge();
+
+Loop::futureTick(async(static function () use ($eventLoopBridge) {
+    $future = run(function (): string {
+        return 'Hello World!';
+    });
+
+    echo $eventLoopBridge->await($future), PHP_EOL;
+}));