@@ -114,10 +114,10 @@ |
||
| 114 | 114 | |
| 115 | 115 | return ($desiredTimeout !== RequestExecutorInterface::WAIT_FOREVER) && |
| 116 | 116 | ( |
| 117 | - ($hasConnected && $lastOperationTime !== null) || |
|
| 117 | + ($hasConnected && $lastOperationTime !== null) || |
|
| 118 | 118 | !$hasConnected |
| 119 | - ) && |
|
| 119 | + ) && |
|
| 120 | 120 | ($microTime - $lastOperationTime >= $desiredTimeout) |
| 121 | - ; |
|
| 121 | + ; |
|
| 122 | 122 | } |
| 123 | 123 | } |
@@ -136,13 +136,13 @@ |
||
| 136 | 136 | private function isDisconnectRequired(SocketInterface $socket) |
| 137 | 137 | { |
| 138 | 138 | return ( |
| 139 | - ($socket instanceof PersistentClientSocket) && |
|
| 139 | + ($socket instanceof PersistentClientSocket) && |
|
| 140 | 140 | ( |
| 141 | - feof($socket->getStreamResource()) !== false || |
|
| 141 | + feof($socket->getStreamResource()) !== false || |
|
| 142 | 142 | !stream_socket_get_name($socket->getStreamResource(), true) |
| 143 | - ) |
|
| 144 | - ) || ( |
|
| 145 | - !($socket instanceof PersistentClientSocket) |
|
| 146 | - ); |
|
| 143 | + ) |
|
| 144 | + ) || ( |
|
| 145 | + !($socket instanceof PersistentClientSocket) |
|
| 146 | + ); |
|
| 147 | 147 | } |
| 148 | 148 | } |
@@ -123,9 +123,9 @@ |
||
| 123 | 123 | $operation = $descriptor->getOperation(); |
| 124 | 124 | return ($operation instanceof NullOperation) || |
| 125 | 125 | ( |
| 126 | - $operation instanceof ReadOperation && |
|
| 126 | + $operation instanceof ReadOperation && |
|
| 127 | 127 | $operation->getFramePicker() instanceof EmptyFramePicker |
| 128 | - ); |
|
| 128 | + ); |
|
| 129 | 129 | } |
| 130 | 130 | |
| 131 | 131 | /** |