@@ -102,12 +102,12 @@ discard block |
||
| 102 | 102 | if ($positionCrlf === false) { |
| 103 | 103 | // Header shouldn't be bigger than 1024 bytes |
| 104 | 104 | if (isset($this->buffer[static::MAX_CHUNK_HEADER_SIZE])) { |
| 105 | - $this->handleError(new Exception('Chunk header size inclusive extension bigger than' . static::MAX_CHUNK_HEADER_SIZE. ' bytes')); |
|
| 105 | + $this->handleError(new Exception('Chunk header size inclusive extension bigger than' . static::MAX_CHUNK_HEADER_SIZE . ' bytes')); |
|
| 106 | 106 | } |
| 107 | 107 | return; |
| 108 | 108 | } |
| 109 | 109 | |
| 110 | - $header = \strtolower((string)\substr($this->buffer, 0, $positionCrlf)); |
|
| 110 | + $header = \strtolower((string) \substr($this->buffer, 0, $positionCrlf)); |
|
| 111 | 111 | $hexValue = $header; |
| 112 | 112 | |
| 113 | 113 | if (\strpos($header, ';') !== false) { |
@@ -128,19 +128,19 @@ discard block |
||
| 128 | 128 | return; |
| 129 | 129 | } |
| 130 | 130 | |
| 131 | - $this->buffer = (string)\substr($this->buffer, $positionCrlf + 2); |
|
| 131 | + $this->buffer = (string) \substr($this->buffer, $positionCrlf + 2); |
|
| 132 | 132 | $this->headerCompleted = true; |
| 133 | 133 | if ($this->buffer === '') { |
| 134 | 134 | return; |
| 135 | 135 | } |
| 136 | 136 | } |
| 137 | 137 | |
| 138 | - $chunk = (string)\substr($this->buffer, 0, $this->chunkSize - $this->transferredSize); |
|
| 138 | + $chunk = (string) \substr($this->buffer, 0, $this->chunkSize - $this->transferredSize); |
|
| 139 | 139 | |
| 140 | 140 | if ($chunk !== '') { |
| 141 | 141 | $this->transferredSize += \strlen($chunk); |
| 142 | 142 | $this->emit('data', array($chunk)); |
| 143 | - $this->buffer = (string)\substr($this->buffer, \strlen($chunk)); |
|
| 143 | + $this->buffer = (string) \substr($this->buffer, \strlen($chunk)); |
|
| 144 | 144 | } |
| 145 | 145 | |
| 146 | 146 | $positionCrlf = \strpos($this->buffer, static::CRLF); |
@@ -154,10 +154,10 @@ discard block |
||
| 154 | 154 | $this->chunkSize = 0; |
| 155 | 155 | $this->headerCompleted = false; |
| 156 | 156 | $this->transferredSize = 0; |
| 157 | - $this->buffer = (string)\substr($this->buffer, 2); |
|
| 157 | + $this->buffer = (string) \substr($this->buffer, 2); |
|
| 158 | 158 | } elseif ($this->chunkSize === 0) { |
| 159 | 159 | // end chunk received, skip all trailer data |
| 160 | - $this->buffer = (string)\substr($this->buffer, $positionCrlf); |
|
| 160 | + $this->buffer = (string) \substr($this->buffer, $positionCrlf); |
|
| 161 | 161 | } |
| 162 | 162 | |
| 163 | 163 | if ($positionCrlf !== 0 && $this->chunkSize !== 0 && $this->chunkSize === $this->transferredSize && \strlen($this->buffer) > 2) { |
@@ -82,7 +82,7 @@ discard block |
||
| 82 | 82 | |
| 83 | 83 | $promise = $this->connectionManager->connect($this->request->getUri()); |
| 84 | 84 | $promise->then( |
| 85 | - function (ConnectionInterface $connection) use ($headers, &$connectionRef, &$stateRef, &$pendingWrites, $that) { |
|
| 85 | + function(ConnectionInterface $connection) use ($headers, &$connectionRef, &$stateRef, &$pendingWrites, $that) { |
|
| 86 | 86 | $connectionRef = $connection; |
| 87 | 87 | assert($connectionRef instanceof ConnectionInterface); |
| 88 | 88 | |
@@ -194,7 +194,7 @@ discard block |
||
| 194 | 194 | $connectionManager = $this->connectionManager; |
| 195 | 195 | $successfulEndReceived = false; |
| 196 | 196 | $input = $body = new CloseProtectionStream($connection); |
| 197 | - $input->on('close', function () use ($connection, $that, $connectionManager, $request, $response, &$successfulEndReceived) { |
|
| 197 | + $input->on('close', function() use ($connection, $that, $connectionManager, $request, $response, &$successfulEndReceived) { |
|
| 198 | 198 | // only reuse connection after successful response and both request and response allow keep alive |
| 199 | 199 | if ($successfulEndReceived && $connection->isReadable() && $that->hasMessageKeepAliveEnabled($response) && $that->hasMessageKeepAliveEnabled($request)) { |
| 200 | 200 | $connectionManager->keepAlive($request->getUri(), $connection); |
@@ -216,7 +216,7 @@ discard block |
||
| 216 | 216 | $length = (int) $response->getHeaderLine('Content-Length'); |
| 217 | 217 | } |
| 218 | 218 | $response = $response->withBody($body = new ReadableBodyStream($body, $length)); |
| 219 | - $body->on('end', function () use (&$successfulEndReceived) { |
|
| 219 | + $body->on('end', function() use (&$successfulEndReceived) { |
|
| 220 | 220 | $successfulEndReceived = true; |
| 221 | 221 | }); |
| 222 | 222 | |
@@ -40,7 +40,7 @@ discard block |
||
| 40 | 40 | $buffer = ''; |
| 41 | 41 | $maxSize = $this->maxSize; |
| 42 | 42 | $that = $this; |
| 43 | - $conn->on('data', $fn = function ($data) use (&$buffer, &$fn, $conn, $maxSize, $that) { |
|
| 43 | + $conn->on('data', $fn = function($data) use (&$buffer, &$fn, $conn, $maxSize, $that) { |
|
| 44 | 44 | // append chunk of data to buffer and look for end of request headers |
| 45 | 45 | $buffer .= $data; |
| 46 | 46 | $endOfHeader = \strpos($buffer, "\r\n\r\n"); |
@@ -68,7 +68,7 @@ discard block |
||
| 68 | 68 | |
| 69 | 69 | try { |
| 70 | 70 | $request = $that->parseRequest( |
| 71 | - (string)\substr($buffer, 0, $endOfHeader + 2), |
|
| 71 | + (string) \substr($buffer, 0, $endOfHeader + 2), |
|
| 72 | 72 | $conn |
| 73 | 73 | ); |
| 74 | 74 | } catch (Exception $exception) { |
@@ -84,7 +84,7 @@ discard block |
||
| 84 | 84 | if ($request->hasHeader('Transfer-Encoding')) { |
| 85 | 85 | $contentLength = null; |
| 86 | 86 | } elseif ($request->hasHeader('Content-Length')) { |
| 87 | - $contentLength = (int)$request->getHeaderLine('Content-Length'); |
|
| 87 | + $contentLength = (int) $request->getHeaderLine('Content-Length'); |
|
| 88 | 88 | } |
| 89 | 89 | |
| 90 | 90 | if ($contentLength === 0) { |
@@ -162,8 +162,8 @@ discard block |
||
| 162 | 162 | |
| 163 | 163 | // remember server params for all requests from this connection, reset on connection close |
| 164 | 164 | $this->connectionParams[$cid] = $serverParams; |
| 165 | - $params =& $this->connectionParams; |
|
| 166 | - $connection->on('close', function () use (&$params, $cid) { |
|
| 165 | + $params = & $this->connectionParams; |
|
| 166 | + $connection->on('close', function() use (&$params, $cid) { |
|
| 167 | 167 | assert(\is_array($params)); |
| 168 | 168 | unset($params[$cid]); |
| 169 | 169 | }); |
@@ -93,7 +93,7 @@ |
||
| 93 | 93 | */ |
| 94 | 94 | public function moveTo($targetPath) |
| 95 | 95 | { |
| 96 | - throw new RuntimeException('Not implemented'); |
|
| 96 | + throw new RuntimeException('Not implemented'); |
|
| 97 | 97 | } |
| 98 | 98 | |
| 99 | 99 | /** |
@@ -42,8 +42,8 @@ |
||
| 42 | 42 | $this->now = \microtime(true); |
| 43 | 43 | |
| 44 | 44 | // remember clock for current loop tick only and update on next tick |
| 45 | - $now =& $this->now; |
|
| 46 | - $this->loop->futureTick(function () use (&$now) { |
|
| 45 | + $now = & $this->now; |
|
| 46 | + $this->loop->futureTick(function() use (&$now) { |
|
| 47 | 47 | assert($now !== null); |
| 48 | 48 | $now = null; |
| 49 | 49 | }); |
@@ -101,7 +101,7 @@ |
||
| 101 | 101 | $this->idleConnections[] = $connection; |
| 102 | 102 | |
| 103 | 103 | $that = $this; |
| 104 | - $cleanUp = function () use ($connection, $that) { |
|
| 104 | + $cleanUp = function() use ($connection, $that) { |
|
| 105 | 105 | // call public method to support legacy PHP 5.3 |
| 106 | 106 | $that->cleanUpConnection($connection); |
| 107 | 107 | }; |
@@ -50,7 +50,7 @@ |
||
| 50 | 50 | } |
| 51 | 51 | |
| 52 | 52 | $that = $this; |
| 53 | - $next = function (ServerRequestInterface $request) use ($that, $position) { |
|
| 53 | + $next = function(ServerRequestInterface $request) use ($that, $position) { |
|
| 54 | 54 | return $that->call($request, $position + 1); |
| 55 | 55 | }; |
| 56 | 56 | |
@@ -16,7 +16,7 @@ discard block |
||
| 16 | 16 | public static function iniSizeToBytes($size) |
| 17 | 17 | { |
| 18 | 18 | if (\is_numeric($size)) { |
| 19 | - return (int)$size; |
|
| 19 | + return (int) $size; |
|
| 20 | 20 | } |
| 21 | 21 | |
| 22 | 22 | $suffix = \strtoupper(\substr($size, -1)); |
@@ -40,9 +40,9 @@ discard block |
||
| 40 | 40 | return $strippedSize * 1024 * 1024 * 1024; |
| 41 | 41 | } |
| 42 | 42 | if ($suffix === 'T') { |
| 43 | - return $strippedSize * 1024 * 1024 * 1024 * 1024; |
|
| 43 | + return $strippedSize * 1024 * 1024 * 1024 * 1024; |
|
| 44 | 44 | } |
| 45 | 45 | |
| 46 | - return (int)$size; |
|
| 46 | + return (int) $size; |
|
| 47 | 47 | } |
| 48 | 48 | } |
@@ -24,8 +24,8 @@ discard block |
||
| 24 | 24 | $this->size = $size; |
| 25 | 25 | |
| 26 | 26 | $that = $this; |
| 27 | - $pos =& $this->position; |
|
| 28 | - $input->on('data', function ($data) use ($that, &$pos, $size) { |
|
| 27 | + $pos = & $this->position; |
|
| 28 | + $input->on('data', function($data) use ($that, &$pos, $size) { |
|
| 29 | 29 | $that->emit('data', array($data)); |
| 30 | 30 | |
| 31 | 31 | $pos += \strlen($data); |
@@ -33,7 +33,7 @@ discard block |
||
| 33 | 33 | $that->handleEnd(); |
| 34 | 34 | } |
| 35 | 35 | }); |
| 36 | - $input->on('error', function ($error) use ($that) { |
|
| 36 | + $input->on('error', function($error) use ($that) { |
|
| 37 | 37 | $that->emit('error', array($error)); |
| 38 | 38 | $that->close(); |
| 39 | 39 | }); |