Skip to content

Commit 6d83543

Browse files
committed
Rename Server to StreamingServer and created a buffering Server facade around StreamingServer
1 parent 19b1cda commit 6d83543

6 files changed

Lines changed: 559 additions & 526 deletions

File tree

README.md

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -9,6 +9,7 @@ Event-driven, streaming plaintext HTTP and secure HTTPS server for [ReactPHP](ht
99

1010
* [Quickstart example](#quickstart-example)
1111
* [Usage](#usage)
12+
* [StreamingServer](#streamingserver)
1213
* [Server](#server)
1314
* [Request](#request)
1415
* [Response](#response)
@@ -45,7 +46,7 @@ See also the [examples](examples).
4546

4647
## Usage
4748

48-
### Server
49+
### StreamingServer
4950

5051
The `Server` class is responsible for handling incoming connections and then
5152
processing each incoming HTTP request.
@@ -55,7 +56,7 @@ constructor with the respective [request](#request) object and expects
5556
a respective [response](#response) object in return.
5657

5758
```php
58-
$server = new Server(function (ServerRequestInterface $request) {
59+
$server = new StreamingServer(function (ServerRequestInterface $request) {
5960
return new Response(
6061
200,
6162
array('Content-Type' => 'text/plain'),

examples/12-upload.php

Lines changed: 1 addition & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -10,9 +10,6 @@
1010
use Psr\Http\Message\ServerRequestInterface;
1111
use Psr\Http\Message\UploadedFileInterface;
1212
use React\EventLoop\Factory;
13-
use React\Http\MiddlewareRunner;
14-
use React\Http\Middleware\RequestBodyBufferMiddleware;
15-
use React\Http\Middleware\RequestBodyParserMiddleware;
1613
use React\Http\Response;
1714
use React\Http\Server;
1815

@@ -118,11 +115,7 @@
118115
};
119116

120117
// buffer and parse HTTP request body before running our request handler
121-
$server = new Server(new MiddlewareRunner(array(
122-
new RequestBodyBufferMiddleware(100000), // 100 KB max
123-
new RequestBodyParserMiddleware(),
124-
$handler
125-
)));
118+
$server = new Server($handler);
126119

127120
$socket = new \React\Socket\Server(isset($argv[1]) ? $argv[1] : '0.0.0.0:0', $loop);
128121
$server->listen($socket);

0 commit comments

Comments
 (0)