Hi,

I have php 7 installed and I tried only working extension "event.so" for ReactPHP on PHP 7, but it doesnt work at all, it just make php to take 99% cpu power and 'freeze'

Testing code

<?php
require __DIR__.'/../vendor/autoload.php';


$loop = \React\EventLoop\Factory::create();
$handler = new \WyriHaximus\React\GuzzlePsr7\HttpClientAdapter($loop);

$client = new \GuzzleHttp\Client([
    'base_uri' => 'http://127.0.0.1/fake_web/',
    'handler' => \GuzzleHttp\HandlerStack::create($handler),
]);

$response = $client->get('http://127.0.0.1/fake_web/'); # ! this is row that stops script !
$html = (string) $response->getBody();

When I try same code with StreamSelectLoop it works

React Http client works with https://developer.gitter.im/docs/streaming-api:

$loop = React\EventLoop\Factory::create();
$react = (new React\HttpClient\Factory())->create($loop, (new React\Dns\Resolver\Factory())->createCached('8.8.8.8', $loop))

$stream = $react->request('GET', 'https://stream.gitter.im/v1/rooms/'.$room.'/chatMessages', $headers);

$stream->on('response', function ($response) {
    $response->on('data', function ($data) {
        var_dump($data);
    });
});
$stream->end();

$loop->run();

This library doesn't work (success function in then not run at all):

$loop = React\EventLoop\Factory::create();

$stack = GuzzleHttp\HandlerStack::create(new WyriHaximus\React\GuzzlePsr7\HttpClientAdapter($loop));
$client = new GuzzleHttp\Client([
    'headers' => $headers,
    'handler' => $stack,
]);

$stream = $client->getAsync('https://stream.gitter.im/v1/rooms/'.$room.'/chatMessages', ['stream' => true]);

$stream->then(function ($response) {
    $body = $response->getBody();
    $data = '';
    while (!$body->eof()) {
        $data .= $body->read(1024);
    }
    var_dump($data);
});

$loop->run();

{
    "name": "mdrost/react-guzzle-test",
    "require": {
        "react/http": "^0.6.0",
        "wyrihaximus/react-guzzle-psr7": "^2.0"
    }
}

outputs

Your requirements could not be resolved to an installable set of packages.

  Problem 1
    - Installation request for react/http ^0.6.0 -> satisfiable by react/http[v0.6.0].
    - Installation request for wyrihaximus/react-guzzle-psr7 ^2.0 -> satisfiable by wyrihaximus/react-guzzle-psr7[2.0.0].
    - wyrihaximus/react-guzzle-http-client 4.0.0 requires clue/socks-react ^0.4.0 -> satisfiable by clue/socks-react[v0.4.0].
    - wyrihaximus/react-guzzle-psr7 2.0.0 requires wyrihaximus/react-guzzle-http-client ^4.0 -> satisfiable by wyrihaximus/react-guzzle-http-client[4.0.0].
    - clue/socks-react v0.4.0 requires react/socket 0.3.*|0.4.* -> satisfiable by react/socket[v0.3.0, v0.3.1, v0.3.2, v0.3.3, v0.3.4, v0.4.0, v0.4.1, v0.4.2, v0.4.3, v0.4.4, v0.4.5, v0.4.6].
    - Can only install one of: react/socket[v0.5.0, v0.3.0].
    - Can only install one of: react/socket[v0.5.0, v0.3.1].
    - Can only install one of: react/socket[v0.5.0, v0.3.2].
    - Can only install one of: react/socket[v0.5.0, v0.3.3].
    - Can only install one of: react/socket[v0.5.0, v0.3.4].
    - Can only install one of: react/socket[v0.5.0, v0.4.0].
    - Can only install one of: react/socket[v0.5.0, v0.4.1].
    - Can only install one of: react/socket[v0.5.0, v0.4.2].
    - Can only install one of: react/socket[v0.5.0, v0.4.3].
    - Can only install one of: react/socket[v0.5.0, v0.4.4].
    - Can only install one of: react/socket[v0.5.0, v0.4.5].
    - Can only install one of: react/socket[v0.5.0, v0.4.6].
    - react/http v0.6.0 requires react/socket ^0.5 -> satisfiable by react/socket[v0.5.0, v0.5.1].
    - Conclusion: don't install react/socket v0.5.1

When sending a large file via multipart/form-data using HTTPS the connection stalls. I am able to reproduce this consistently with php 5.6 and PHP 7 (albeit both have a different limit).

This may or may not be a problem in the underlying reactphp/socket-client or PHP ssl streams.

And here an example to test:

<?php

require_once 'vendor/autoload.php';

use \WyriHaximus\React as ReactHttp;
use React\EventLoop\Factory as LoopFactory;


$loop = LoopFactory::create();
$handler = new ReactHttp\GuzzlePsr7\HttpClientAdapter($loop);
$client = new GuzzleHttp\Client([
    'handler'   => \GuzzleHttp\HandlerStack::create($handler)
]);

// PHP 5.6 works for me until the last number is 86.
// PHP 7.x works for me until the last number is 88
$AS = str_repeat("A", 28462 + 90);
print "MD5SUM = ".md5($AS)."\n";

$client->requestAsync(
    "POST", 
    "https://skizzordz.exis.cl/test-upload.php",
    [
        'multipart' => [
            [   
                "name" => "file", 
                "contents" => $AS,
                "filename" => "A.txt"
            ]
        ]
    ])
    ->then(function($response) {
        print "RESPONSE = ".$response->getStatusCode()."\n";
        print "BODY = ".$response->getBody()."\n";
        die();
    })
    ->otherwise(function(Exception $error) {
        print("ERROR: " . $error->getMessage(). "\n");
        die();
    });

while(1) $loop->run();

Hi, I'm not sure if its possible but I'm trying to poll an API every x seconds. But when I try the following for example the promises never get resolved. Am I doing something wrong?

<?php
require dirname(__DIR__) . '/vendor/autoload.php';

use GuzzleHttp\Client;
use GuzzleHttp\HandlerStack;
use GuzzleHttp\Psr7\Response;
use React\EventLoop\Factory;
use WyriHaximus\React\GuzzlePsr7\HttpClientAdapter;

$loop = Factory::create();

$client = new Client([
    'handler' => HandlerStack::create(new HttpClientAdapter($loop)),
]);

$loop->addPeriodicTimer(5, function() use (&$client) {
    echo 'Loading content', PHP_EOL;

    $promise = $client->getAsync('http://blog.wyrihaximus.net/');
    $promise->then(function(Response $response) { // Success callback
        var_dump($response);
        echo 'Content loaded', PHP_EOL;
    });
});


$loop->run();

My actual use case is within the Amazon EC2 SDK to check if an instance has booted or not.

I'm in the process of rewriting a library that depends on this repo. Today I came across this article which precisely details one way to make guzzle and react play nicely together – however I noticed some differences between your code and his.

Did you base the current structure of your lib on the code in that article? If so, I would assume any differences must be due to your vision for improving on the article's code. If your lib is better, can you point out why?

I'm using the ratchephpt/Pawl WS client on the same loop as the one I've set for this Guzzle handler.

Async requests are generally fine but sync. requests either run instantly and work fine or they hang for a long while and then cause the WebSocket connection to die (Sending or Receiving messages fail without any exceptions).

Using the default Guzzle handler along with Pawl works fine, but I do need async requests so am a bit stuck here.

(Also would it be better if I posted this in reactphp/http-client since it uses that?)

I am writing a function to log input to cloud watch logs. I want it as fast as possible. Normally I use synchronous request, e.g putLogEvents, currently the time difference is about 40ms. My question is how to speed up my putLogEvents or using putLogEventsAsync instead.

Here is my code

public function writeToCloudWatch($line)
   {
        $microTime = $this->timeProvider->getMicroTime();

        if (!isset($this->nextSequenceToken)){
            $responseModel = $this->client->describeLogStreams([
                'logGroupName' => $this->logGroup,
                'logStreamNamePrefix' => $this->logStream,
            ]);
            $this->nextSequenceToken = $responseModel['logStreams']['0']['uploadSequenceToken'];
        }
        try {
            $responseModel = $this->client->putLogEvents([
                'logGroupName' => $this->logGroup,
                'logStreamName' => $this->logStream,
                'logEvents' => [
                    [
                        'message' => $line,
                        'timestamp' => $microTime,
                    ]
                ],
                'sequenceToken' => $this->nextSequenceToken
            ]);
            if (isset($responseModel['nextSequenceToken'])) {
                $this->nextSequenceToken = $responseModel['nextSequenceToken'];
            }
        } catch (CloudWatchLogsException $e) {
            // We don't want any exception when putLogEvents is not working
        }
    }

Hello! I've used your tool for making async requests to AWS S3 buckets. But i got an error:

In FutureTickQueue.php line 46:                                           
Can't shift from an empty datastructure 

It is weird because i don't need ticking manually event loop or calling wait as far as i use custom HTTP handler.

        $loop = EventLoopFactory::create();
        $handler = new \WyriHaximus\React\GuzzlePsr7\HttpClientAdapter($loop);

        $s3Client = new S3Client([
            'http_handler' => \GuzzleHttp\HandlerStack::create($handler),
            'version' => 'latest',
            'region' => getenv('AWS_REGION'),
            'validate' => false
        ]);

        $dir1 = dirname(dirname(__DIR__)) . "/data/temp-test-medium-1";
        mkdir($dir1);
        $s3Client->downloadBucketAsync($dir1, 'test-medium-1')->then(function(){
            echo "Done 1\n";
        });

        $dir2 = dirname(dirname(__DIR__)) . "/data/temp-test-medium-2";
        mkdir($dir2);
        $s3Client->downloadBucketAsync($dir2, 'test-medium-2')->then(function(){
            echo "Done 2\n";
        });

        $loop->run();
        echo "finished\n";

Thanks in advance!

Hi,

I tried with loop example: with send mail, this process like sync as not sent mail in behind.

$loop = \React\EventLoop\Factory::create(); $handler = new \WyriHaximus\React\GuzzlePsr7\HttpClientAdapter($loop);

$client = new \GuzzleHttp\Client([ 'handler' => \GuzzleHttp\HandlerStack::create($handler), ]);

$client->getAsync('http://github.com/')->then(function ($response) { var_export($response); var_export((string) $response->getBody()); });

$client->getAsync('http://php.net/')->then(function ($response) { var_export($response); var_export((string) $response->getBody()); });

$loop->run();

helo how to get result without waiting all request. example :

$loop = \React\EventLoop\Factory::create();
        $handler = new \WyriHaximus\React\GuzzlePsr7\HttpClientAdapter($loop);

        $client = new \GuzzleHttp\Client([
            'handler' => \GuzzleHttp\HandlerStack::create($handler),
        ]);

        $client->getAsync('http://Example4.com')->then(function ($response) {
            var_export($response);
        });

        $client->getAsync('http://Example1.com')->then(function ($response) {
            var_export($response);
        });

        $client->getAsync('http://Example2.com')->then(function ($response) {
            var_export($response);
        });

        $client->getAsync('http://Example3.com')->then(function ($response) {
            var_export($response);

        });

        $loop->run();

how to get result 'http://Example1.com' when sucess without waitting all;

thanks