Welcome to innmind/async

This package is an abstraction on top of Fibers to coordinate multiple tasks asynchronously.

The goal is to easily move the execution of any code built using innmind/operating-system from a synchronous context to an async one. This means that it's easier to experiment running a piece of code asynchronously and then move back if the experiment is not successful. This also means that you can test each part of an asynchronous system synchronously.

Sneak peek

use Innmind\Async\{
    Scheduler,
    Scope\Continuation,
};
use Innmind\OperatingSystem\{
    OperatingSystem,
    Factory,
};
use Innmind\Immutable\Sequence;

Scheduler::of(Factory::build())
    ->sink(null)
    ->with(
        static fn(
            $_,
            OperatingSystem $os,
            Continuation $continuation,
        ) => $continuation
            ->schedule(Sequence::of(
                static fn(OperatingSystem $os) => importUsers($os),
                static fn(OperatingSystem $os) => importProducts($os),
            ))
            ->finish(),
    );