<?php

use Amp\Beanstalk\BeanstalkClient;
use Amp\Loop;

require __DIR__ . "/vendor/autoload.php";

Loop::run(function () {
    $uri = "udp://127.0.0.1:38925";

    $context = \stream_context_create();
    $server = @\stream_socket_server($uri, $errno, $errstr, STREAM_SERVER_BIND, $context);

    if (!$server || $errno) {
        throw new Exception(\sprintf("Could not create server %s: [Error: #%d] %s", $uri, $errno, $errstr), $errno);
    }

    Loop::onReadable($server, function () use ($server) {
        print "Looping..." . PHP_EOL;
        $packet = \stream_socket_recvfrom($server, 512, null, $remoteAddr);
        print $remoteAddr . " - " . $packet . PHP_EOL;
    });
});