@@ -239,8 +239,8 @@ discard block |
||
239 | 239 | */ |
240 | 240 | public function removeAllSocketOperations(StreamResourceInterface $streamResource) |
241 | 241 | { |
242 | - $opList = [ OperationInterface::OPERATION_READ, |
|
243 | - OperationInterface::OPERATION_WRITE ]; |
|
242 | + $opList = [OperationInterface::OPERATION_READ, |
|
243 | + OperationInterface::OPERATION_WRITE]; |
|
244 | 244 | |
245 | 245 | foreach ($opList as $op) { |
246 | 246 | $this->removeSocketOperation($streamResource, $op); |
@@ -281,8 +281,7 @@ discard block |
||
281 | 281 | */ |
282 | 282 | private function calculateAttemptsCount($seconds, $usec) |
283 | 283 | { |
284 | - $result = $seconds !== null ? ceil(($seconds * 1E6 + $usec) / self::ATTEMPT_DELAY) : |
|
285 | - self::ATTEMPT_COUNT_FOR_INFINITE_TIMEOUT; |
|
284 | + $result = $seconds !== null ? ceil(($seconds * 1E6 + $usec) / self::ATTEMPT_DELAY) : self::ATTEMPT_COUNT_FOR_INFINITE_TIMEOUT; |
|
286 | 285 | if ($result < self::ATTEMPT_COUNT_FOR_INFINITE_TIMEOUT) { |
287 | 286 | $result = self::ATTEMPT_COUNT_FOR_INFINITE_TIMEOUT; |
288 | 287 | } |