edefimov / async-sockets

src/RequestExecutor/LibEvent/LeBase.php

Spacing +3 added lines, -3 removed lines

@@ -211,9 +211,9 @@
     private function onEvent(LeEvent $event, $eventFlags)
     {
         $map = [
-            LeCallbackInterface::EVENT_READ    => [ EV_READ, RequestDescriptor::RDS_READ ],
-            LeCallbackInterface::EVENT_WRITE   => [ EV_WRITE, RequestDescriptor::RDS_WRITE ],
-            LeCallbackInterface::EVENT_TIMEOUT => [ EV_TIMEOUT, 0 ],
+            LeCallbackInterface::EVENT_READ    => [EV_READ, RequestDescriptor::RDS_READ],
+            LeCallbackInterface::EVENT_WRITE   => [EV_WRITE, RequestDescriptor::RDS_WRITE],
+            LeCallbackInterface::EVENT_TIMEOUT => [EV_TIMEOUT, 0],
         ];
 
         $descriptor = $event->getRequestDescriptor();

src/RequestExecutor/Pipeline/AbstractOobHandler.php

Spacing +1 added lines, -1 removed lines

@@ -104,7 +104,7 @@
         return new Event(
             $this->executor,
             $operation->getSocket(),
-            $meta[ RequestExecutorInterface::META_USER_CONTEXT ],
+            $meta[RequestExecutorInterface::META_USER_CONTEXT],
             $eventName
         );
     }