Coroutine Library

Coroutine Library

OpenSwoole Library is a group of OpenSwoole Coroutine build-in functions implmeneted with PHP.

• OpenSwoole\Coroutine\WaitGroup

• OpenSwoole\Coroutine\Barrier

• OpenSwoole\Coroutine\Batch

• OpenSwoole\Coroutine\map

• OpenSwoole\ConnectionPool

• OpenSwoole\Database\PDOPool

• OpenSwoole\Database\MySQLiPool

• OpenSwoole\Database\RedisPool

OpenSwoole Coroutine Server

Coroutine TCP Server can be created dynamically and used in Coroutine context. The methods and features are the same as OpenSwoole\Server.

Example

<?php
declare(strict_types=1);

use OpenSwoole\Coroutine\Server;
use OpenSwoole\Coroutine\Server\Connection;
go(function () {
    $server = new Server('0.0.0.0', 9601, false);
    $server->handle(function (Connection $conn) use ($server) {
        while('' !== $data = $conn->recv()) {
            $json = json_decode($data, true);
            if(is_array($json) && 'hello' === $json['data']) {
                $conn->send("world\n");
            }
        }
        echo 'disconnected', PHP_EOL;
    });
    $server->start();
});