Trying to listing on socket, works in some cases not in all

[LEDfan]

Hi, thanks for this project 😃.

I'm using this code from the README.md, with a small adjustment to output any data send to it.

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

    $socket = new React\Socket\Server($loop);
    $socket->on('connection', function ($conn) {
    echo "New connection " . $conn->getRemoteAddress() . "\n";


        $conn->on('data', function ($data) use ($conn) {
        echo "New msg from " . $conn->getRemoteAddress() . " msg: " . $data . "\n";
           $conn->close();
        });
    });
    $socket->listen(1337);

    $loop->run();

This works perfect if you start a netcat shell: nc localhost 6461, and type some data into it. However when I try to pipe some data to netcat e.g. echo "test" | nc localhost 6461, the connection is received (I see the new connection msg and ip address). However the data isn't received.

Is this normal behaviour or is this a bug? I'm trying to "catch" output from an existing service, which I can't change.

Thanks! (If you give me some hints where the bug is, I'll be happy to open a PR)

[LEDfan]

The end event on the $conn object is called directly after executing the netcat command.

[LEDfan]

BTW this is the perl code which I try to use: https://github.com/stevenshiau/clonezilla/blob/master/bin/ocs-socket by issuing ocs-socket -h ip -p 6461 -m test. This doesn’t works the first time, but it does the second time.

[LEDfan]

I think I found the problem: http://stackoverflow.com/questions/15163778/perl-tcp-client-does-not-display-incoming-data & http://stackoverflow.com/questions/993217/php-to-perl-socket-communication.
React is waiting for a full line, but per/netcat doesn't send it. However simply sending "\n" doesn't works.

[LEDfan]

🎆 just looked at it again, and my assumption in the last post was correct, in the code I fetched via composer there is this:

if ('' === $data || false === $data || feof($stream)) {

Which checks if there is and end of file before emitting the data.

However in this code repo there is this line https://github.com/reactphp/socket/blob/master/src/Connection.php#L14

Which works perfect 😃. So the problem was I was using and old ratchet/react version.....

[staabm]

@LEDfan Was it a typo in your composer.json (version constraint) or does the latest version which is provided by composer/packagist not contain the correct line?

[LEDfan]

@staabm I first had:

   "require": {
        "cboden/Ratchet": "0.3.*",
        "react/zmq": "0.2.*",
        "phpseclib/phpseclib": "2.0.*@dev"
    }

Now I have:

   "require": {
     "cboden/ratchet": "0.3.*",
    "react/zmq": "0.3.*",
    "phpseclib/phpseclib": "0.3.*"
  }