WIP

src/PostgresLink.php

@@ -2,11 +2,22 @@
 
 namespace Amp\Postgres;
 
+use Amp\Sql\ConnectionException;
 use Amp\Sql\Link;
+use Amp\Sql\QueryError;
+use Amp\Sql\SqlException;
 
 /**
  * @extends Link<PostgresResult, PostgresStatement, PostgresTransaction>
  */
-interface PostgresLink extends Link, PostgresReceiver
+interface PostgresLink extends Link
 {
+    /**
+     * @param non-empty-string $channel Channel name.
+     *
+     * @throws SqlException If the operation fails due to unexpected condition.
+     * @throws ConnectionException If the connection to the database is lost.
+     * @throws QueryError If the operation fails due to an error in the query (such as a syntax error).
+     */
+    public function listen(string $channel): PostgresListener;
 }