carno-php / nsq

src/Chips/LookupAssigned.php

Spacing +1 added lines, -1 removed lines

@@ -32,7 +32,7 @@
      */
     public function hasLookupd() : bool
     {
-        return ! is_null($this->lookupd);
+        return !is_null($this->lookupd);
     }
 
     /**

src/Chips/InteractiveChan.php

Spacing +1 added lines, -1 removed lines

@@ -39,6 +39,6 @@
      */
     private function queued() : bool
     {
-        return !! $this->chan;
+        return !!$this->chan;
     }
 }

src/Protocol/Buffer.php

Spacing +1 added lines, -1 removed lines

@@ -40,7 +40,7 @@
      */
     public function valid() : bool
     {
-        return ! $this->eof();
+        return !$this->eof();
     }
 
     /**

src/Protocol/Subscribe.php

Spacing +1 added lines, -1 removed lines

@@ -23,7 +23,7 @@
      */
     public function __construct(Promised $connected, Nsqd $nsqd, Consuming $consuming)
     {
-        go(static function () use ($connected, $nsqd, $consuming) {
+        go(static function() use ($connected, $nsqd, $consuming) {
             if (yield $connected) {
                 if (yield $nsqd->sub($consuming->topic(), $consuming->channel())) {
                     $nsqd->rdy($consuming->concurrency());

src/Components/Lookupd.php

Spacing +2 added lines, -2 removed lines

@@ -67,7 +67,7 @@ 
     {
         $this->observers[] = $observer;
 
-        $querying = function () use ($topic) {
+        $querying = function() use ($topic) {
             /**
              * @var Response $response
              */
@@ -76,7 +76,7 @@ 
             $response = yield $this->http->perform($request);
             switch ($response->getStatusCode()) {
                 case 200:
-                    $endpoints = $this->parsing((string)$response->getBody());
+                    $endpoints = $this->parsing((string) $response->getBody());
                     if ($this->observers) {
                         foreach ($this->observers as $observer) {
                             yield $observer($endpoints);