Using grpc bidirectional streaming in swoole

[Domex777]

I try to create a simple grpc bidirectional streaming server and client for transfer messages between services, and i came across the fact that I can't start receiving a response from the server until I explicitly indicate that the message is the last one. Although I found a lot of information that the server can respond to each message gradually.

Example server and client

Server

$http = new Server('0.0.0.0', 50051, SWOOLE_BASE);
$http->set([
    "log_level" => SWOOLE_LOG_INFO,
    "trace_flags" => 0,
    "worker_num" => 1,
    "open_http2_protocol" => true
]);
$http->on('workerStart', function (Server $server) {
    echo "w s";
});

$http->on('connect', function (Server $server, int $fd, int $reactorId) {
    var_dump($server->getClientInfo($fd));
});

$http->on('request', function (Request $request, Response $response) use ($http) {
    var_dump($request);
});

$http->start();

Client

run(function () {
    $client = new Client('host.docker.internal', 50051);

    if (!$client->connect()) {
        echo "Connection failed\n";
        return;
    }
    
    $request = new Request();
    $request->pipeline = true;
    
    $request->headers = [
        'content-type' => 'application/grpc',
        'te' => 'trailers'
    ];

    $data = "test message";
    $request->data = pack('CN', 0, strlen($data)) . $data;

    $streamId = $client->send($request);
    var_dump($streamId);
    go(function () use ($client, $streamId) {
        for ($i = 0; $i < 10; $i++) {
            $data = "test message";
            $data = pack('CN', 0, strlen($data)) . $data;
            dump($client->write($streamId, $data));

            Coroutine::sleep(1);
        }
    });


    if ($streamId > 0) {
        while (true) {
            $response = $client->read(-1);
            dump($response);
            if ($response) {
                echo "Response received\n";
                var_dump($response->data);
            }
            Coroutine::sleep(1);
        }
    }

    $client->close();
});

Swoole 6
Gcc version 13.2.1 20240309 (Alpine 13.2.1_git20240309) 
PHP 8.4.1 (cli) 

[NathanFreeman]

I will test it later.

[matyhtf]

Swoole\Http\Server does not currently support streaming data; it waits for the client to send all HTTP chunks before triggering the onRequest event.