|
1 | 1 | # EventLoop Component
|
2 | 2 |
|
3 |
| -[](http://travis-ci.org/reactphp/event-loop) [](https://codeclimate.com/github/reactphp/event-loop) |
| 3 | +[](https://travis-ci.org/reactphp/event-loop) |
| 4 | +[](https://codeclimate.com/github/reactphp/event-loop) |
4 | 5 |
|
5 | 6 | Event loop abstraction layer that libraries can use for evented I/O.
|
6 | 7 |
|
@@ -35,33 +36,35 @@ All of the loops support these features:
|
35 | 36 | ## Usage
|
36 | 37 |
|
37 | 38 | Here is an async HTTP server built with just the event loop.
|
| 39 | + |
38 | 40 | ```php
|
39 |
| - $loop = React\EventLoop\Factory::create(); |
40 |
| - |
41 |
| - $server = stream_socket_server('tcp://127.0.0.1:8080'); |
42 |
| - stream_set_blocking($server, 0); |
43 |
| - $loop->addReadStream($server, function ($server) use ($loop) { |
44 |
| - $conn = stream_socket_accept($server); |
45 |
| - $data = "HTTP/1.1 200 OK\r\nContent-Length: 3\r\n\r\nHi\n"; |
46 |
| - $loop->addWriteStream($conn, function ($conn) use (&$data, $loop) { |
47 |
| - $written = fwrite($conn, $data); |
48 |
| - if ($written === strlen($data)) { |
49 |
| - fclose($conn); |
50 |
| - $loop->removeStream($conn); |
51 |
| - } else { |
52 |
| - $data = substr($data, $written); |
53 |
| - } |
54 |
| - }); |
55 |
| - }); |
| 41 | +$loop = React\EventLoop\Factory::create(); |
56 | 42 |
|
57 |
| - $loop->addPeriodicTimer(5, function () { |
58 |
| - $memory = memory_get_usage() / 1024; |
59 |
| - $formatted = number_format($memory, 3).'K'; |
60 |
| - echo "Current memory usage: {$formatted}\n"; |
| 43 | +$server = stream_socket_server('tcp://127.0.0.1:8080'); |
| 44 | +stream_set_blocking($server, 0); |
| 45 | +$loop->addReadStream($server, function ($server) use ($loop) { |
| 46 | + $conn = stream_socket_accept($server); |
| 47 | + $data = "HTTP/1.1 200 OK\r\nContent-Length: 3\r\n\r\nHi\n"; |
| 48 | + $loop->addWriteStream($conn, function ($conn) use (&$data, $loop) { |
| 49 | + $written = fwrite($conn, $data); |
| 50 | + if ($written === strlen($data)) { |
| 51 | + fclose($conn); |
| 52 | + $loop->removeStream($conn); |
| 53 | + } else { |
| 54 | + $data = substr($data, $written); |
| 55 | + } |
61 | 56 | });
|
| 57 | +}); |
62 | 58 |
|
63 |
| - $loop->run(); |
| 59 | +$loop->addPeriodicTimer(5, function () { |
| 60 | + $memory = memory_get_usage() / 1024; |
| 61 | + $formatted = number_format($memory, 3).'K'; |
| 62 | + echo "Current memory usage: {$formatted}\n"; |
| 63 | +}); |
| 64 | + |
| 65 | +$loop->run(); |
64 | 66 | ```
|
| 67 | + |
65 | 68 | **Note:** The factory is just for convenience. It tries to pick the best
|
66 | 69 | available implementation. Libraries `SHOULD` allow the user to inject an
|
67 | 70 | instance of the loop. They `MAY` use the factory when the user did not supply
|
|
0 commit comments