Update to new pipeline lib

composer.json

@@ -8,18 +8,21 @@
         "asynchronous",
         "async"
     ],
-    "homepage": "http://amphp.org",
+    "homepage": "https://amphp.org",
     "license": "MIT",
     "require": {
         "php": ">=8",
-        "amphp/amp": "^3-dev"
+        "amphp/amp": "^3-dev",
+        "amphp/pipeline": "dev-master"
     },
     "require-dev": {
         "amphp/php-cs-fixer-config": "dev-master",
         "amphp/phpunit-util": "^2-dev",
         "phpunit/phpunit": "^9",
-        "psalm/phar": "^3.11@dev"
+        "psalm/phar": "^4.10"
     },
+    "minimum-stability": "dev",
+    "prefer-stable": true,
     "autoload": {
         "psr-4": {
             "Amp\\Sql\\": "src"

src/ConnectionConfig.php

@@ -59,8 +59,13 @@ abstract class ConnectionConfig
         return $values;
     }
 
-    public function __construct(string $host, int $port, ?string $user = null, ?string $password = null, ?string $database = null)
-    {
+    public function __construct(
+        string $host,
+        int $port,
+        ?string $user = null,
+        ?string $password = null,
+        ?string $database = null
+    ) {
         $this->host = $host;
         $this->port = $port;
         $this->user = $user;
@@ -95,7 +100,7 @@ abstract class ConnectionConfig
     /**
      * @return string|null
      */
-    final public function getUser() /* : ?string */
+    final public function getUser(): ?string
     {
         return $this->user;
     }
@@ -110,7 +115,7 @@ abstract class ConnectionConfig
     /**
      * @return string|null
      */
-    final public function getPassword() /* : ?string */
+    final public function getPassword(): ?string
     {
         return $this->password;
     }
@@ -125,7 +130,7 @@ abstract class ConnectionConfig
     /**
      * @return string|null
      */
-    final public function getDatabase() /* : ?string */
+    final public function getDatabase(): ?string
     {
         return $this->database;
     }

src/Result.php

@@ -2,7 +2,7 @@
 
 namespace Amp\Sql;
 
-use Amp\Pipeline;
+use Amp\Pipeline\Pipeline;
 
 interface Result extends Pipeline
 {