Implement asynchronous server

[thekid]

It supports protocols where handleData() returns a generator function to yield back control to the server, e.g. during lengthy up- or download operations. Here's a web application showcasing this:

<?php

use io\File;
use web\Application;

class Hello extends Application {

  public function routes() {
    return [
      '/download' => function($req, $res) {
        $target= new File('download.mp4');
        $target->open(File::READ);

        $res->answer(200, 'OK');
        $res->header('Content-Type', 'video/mp4');

        try {
          $out= $res->stream($target->size());
          do {
            $out->write($target->read(16384));
            yield;
          } while (!$target->eof());
        } finally {
          $target->close();
        }
      },
      '/block' => function($req, $res) {
        $target= new File('download.mp4');
        $res->transfer($target->in(), 'video/mp4', $target->size());
      },
      '/' => function($req, $res) {
        $res->answer(200, 'OK');
        $res->send('Hello World', 'text/plain');
      },
    ];
  }
}

For backwards compatibility, this is implemented in a new server class called peer.server.AsyncServer. However, this will become the default with the next major release.

[thekid]

"Isn't this slow?" - I thought - indirectly invoking methods via an array?

use peer\Socket;
use util\profiling\Timer;

class Protocol {

  public function handleData($socket) {
    return $socket->toString();
  }
}

$protocol= new Protocol();
$invoke= [[$protocol, 'handleData']];
$socket= new Socket('127.0.0.1', 8080);

$timer= (new Timer())->start();
for ($i= 0; $i < 10_000_000; $i++) {
  // $result= ($f= $invoke[0] ?? null) ? $f($socket) : null;
  $result= $protocol->handleData($socket);
}

printf("%.3f seconds: %s\n", $timer->elapsedTime(), $result);

• Indirect: 5.791 seconds: peer.Socket((closed) -> tcp://127.0.0.1:8080)
• Direct: 4.877 seconds: peer.Socket((closed) -> tcp://127.0.0.1:8080)

So yes, this is one second difference, but for 10 million invocations (so only 1_000 / 10_000_000 = 0.0001 milliseconds difference per invocation)! Compared to the socket I/O we're handling

[thekid]

Released in https://github.com/xp-framework/networking/releases/tag/v10.1.0