innmind/async-operating-system

This package is abandoned and no longer maintained. The author suggests using the innmind/mantle package instead.

1.0.0 2023-02-11 14:27 UTC

Requires

• php: ~8.1
• innmind/async-socket: ~1.0
• innmind/async-stream: ~1.0
• innmind/async-time-warp: ~1.0
• innmind/http-transport: ~6.4
• innmind/mantle: ~1.0
• innmind/operating-system: ^3.5

Requires (Dev)

• innmind/black-box: ~4.10
• innmind/coding-standard: ~2.0
• phpunit/phpunit: ~9.0
• vimeo/psalm: ~5.6

MIT

• Baptiste Langlade

README

Async implementation of innmind/operating-system to allow to switch to another task when doing any I/O of suspending the current process.

Warning: the following features are disabled in this async context :

• Process forking
• Handling signals

Note: SQL connections are not async yet.

Installation

composer require innmind/async-operating-system

Usage

use Innmind\Async\OperatingSystem\Factory;
use Innmind\OperatingSystem\Factory as Synchronous;
use Innmind\Filesystem\Name;
use Innmind\Http\{
    Message\Request\Request,
    Message\Method,
    ProtocolVersion,
};
use Innmind\Url\{
    Url,
    Path,
};
use Innmind\Mantle\{
    Source\Predetermined,
    Suspend,
    Forerunner,
};

$synchronous = Synchronous::build();
$factory = Factory::of($synchronous);
$source = Predetermined::of(
    static fn(Suspend $suspend) => $factory
        ->build($suspend)
        ->filesystem()
        ->mount(Path::of('somewhere/'))
        ->get(Name::of('some-file'))
        ->match(
            static fn($file) => doYourStuff($file),
            static fn() => null,
        ),
    static fn(Suspend $suspend) => $factory
        ->build($suspend)
        ->remote()
        ->http()(new Request(
            Url::of('https://wikipedia.org')
            Method::get,
            ProtocolVersion::v11,
        ))
        ->match(
            static fn($success) => doYourStuff($success),
            static fn() => null,
        );
);

Forerunner::of($synchronous->clock())(null, $source);

In this example we load a file and call wikipedia asynchronously, but you can use the OperatingSystem returned by $factory->build($suspend) like you would for its synchronous counterpart.