Unreference instead of disable read watcher

Author: trowski

src/PgSqlHandle.php

@@ -121,7 +121,7 @@ public function __construct($handle, $socket)
             $deferred->resolve(\pg_get_result($handle));
 
             if (!$deferred && empty($listeners)) {
-                Loop::disable($watcher);
+                Loop::unreference($watcher);
             }
         });
 
@@ -147,7 +147,8 @@ public function __construct($handle, $socket)
             }
         });
 
-        Loop::disable($this->poll);
+        //Loop::disable($this->poll);
+        Loop::unreference($this->poll);
         Loop::disable($this->await);
     }
 
@@ -233,7 +234,7 @@ private function send(callable $function, ...$args): \Generator
 
         $this->deferred = new Deferred;
 
-        Loop::enable($this->poll);
+        Loop::reference($this->poll);
         if (0 === $result) {
             Loop::enable($this->await);
         }
@@ -466,7 +467,7 @@ public function listen(string $channel): Promise
                 throw $exception;
             }
 
-            Loop::enable($this->poll);
+            //Loop::enable($this->poll);
             return new ConnectionListener($emitter->iterate(), $channel, \Closure::fromCallable([$this, 'unlisten']));
         });
     }

src/PqHandle.php

@@ -87,7 +87,7 @@ public function __construct(pq\Connection $handle)
             $deferred->resolve($handle->getResult());
 
             if (!$deferred && empty($listeners)) {
-                Loop::disable($watcher);
+                Loop::unreference($watcher);
             }
         });
 
@@ -112,7 +112,7 @@ public function __construct(pq\Connection $handle)
             Loop::disable($watcher);
         });
 
-        Loop::disable($this->poll);
+        Loop::unreference($this->poll);
         Loop::disable($this->await);
     }
 
@@ -192,7 +192,7 @@ private function send(?string $sql, callable $method, ...$args): \Generator
 
             $handle = $method(...$args);
 
-            Loop::enable($this->poll);
+            Loop::reference($this->poll);
             if (!$this->handle->flush()) {
                 Loop::enable($this->await);
             }
@@ -253,7 +253,7 @@ private function fetch(): \Generator
         } else {
             $this->deferred = new Deferred;
 
-            Loop::enable($this->poll);
+            Loop::reference($this->poll);
             if (!$this->handle->flush()) {
                 Loop::enable($this->await);
             }
@@ -461,7 +461,7 @@ static function (string $channel, string $message, int $pid) use ($emitter) {
                 throw $exception;
             }
 
-            Loop::enable($this->poll);
+            Loop::reference($this->poll);
             return new ConnectionListener($emitter->iterate(), $channel, \Closure::fromCallable([$this, 'unlisten']));
         });
     }