@@ -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 | /** |