edefimov / async-sockets

src/Operation/ReadWriteOperation.php

Spacing +2 added lines, -4 removed lines

@@ -105,8 +105,7 @@ 
     public function getReadOperation()
     {
         return !empty($this->queue[OperationInterface::OPERATION_READ]) ?
-            reset($this->queue[OperationInterface::OPERATION_READ]) :
-            null;
+            reset($this->queue[OperationInterface::OPERATION_READ]) : null;
     }
 
     /**
@@ -117,8 +116,7 @@ 
     public function getWriteOperation()
     {
         return !empty($this->queue[OperationInterface::OPERATION_WRITE]) ?
-            reset($this->queue[OperationInterface::OPERATION_WRITE]) :
-            null;
+            reset($this->queue[OperationInterface::OPERATION_WRITE]) : null;
     }
 
     /**

src/RequestExecutor/Pipeline/IoStage.php

Spacing +2 added lines, -2 removed lines

@@ -84,7 +84,7 @@ 
     {
         $operation = $requestDescriptor->getOperation();
         if (!$this->ioHandler->supports($operation)) {
-            throw new \LogicException('There is no handler able to process ' . get_class($operation) . ' operation.');
+            throw new \LogicException('There is no handler able to process '.get_class($operation).' operation.');
         }
 
         return $this->ioHandler;
@@ -159,7 +159,7 @@ 
     private function setConnectionFinishTime(RequestDescriptor $requestDescriptor)
     {
         $meta         = $requestDescriptor->getMetadata();
-        $wasConnected = $meta[ RequestExecutorInterface::META_CONNECTION_FINISH_TIME ] !== null;
+        $wasConnected = $meta[RequestExecutorInterface::META_CONNECTION_FINISH_TIME] !== null;
         $this->setSocketOperationTime($requestDescriptor, RequestExecutorInterface::META_CONNECTION_FINISH_TIME);
         if (!$wasConnected) {
             $event = $this->createEvent($requestDescriptor, EventType::CONNECTED);

src/RequestExecutor/Pipeline/ReadWriteIoHandler.php

Spacing +2 added lines, -4 removed lines

@@ -62,8 +62,7 @@ 
     ) {
         /** @var ReadWriteOperation $operation */
         $sequence = $operation->isReadFirst() ?
-            [$operation->getReadOperation(), $operation->getWriteOperation()] :
-            [$operation->getWriteOperation(), $operation->getReadOperation()];
+            [$operation->getReadOperation(), $operation->getWriteOperation()] : [$operation->getWriteOperation(), $operation->getReadOperation()];
         $sequence = array_filter($sequence);
 
         foreach ($sequence as $op) {
@@ -78,8 +77,7 @@ 
         }
 
         return $operation->getReadOperation() !== null || $operation->getWriteOperation() !== null ?
-            $operation :
-            null;
+            $operation : null;
     }
 
     /**

src/RequestExecutor/Pipeline/DelegatingIoHandler.php

Spacing +1 added lines, -2 removed lines

@@ -59,8 +59,7 @@
     ) {
         $handler = $this->getHandler($operation);
         return $handler ?
-            $handler->handle($operation, $descriptor, $executor, $eventHandler, $executionContext) :
-            null;
+            $handler->handle($operation, $descriptor, $executor, $eventHandler, $executionContext) : null;
     }
 
     /**