|
@@ -239,8 +239,8 @@ discard block |
|
|
block discarded – undo |
|
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 |
|
|
block discarded – undo |
|
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
|
} |
Please login to merge, or discard this patch.