diff --git a/src/PgSqlHandle.php b/src/PgSqlHandle.php
index ba5278d..9c7e5d1 100644
--- a/src/PgSqlHandle.php
+++ b/src/PgSqlHandle.php
@@ -101,7 +101,7 @@ final class PgSqlHandle implements Handle
                 $notification->channel = $channel;
                 $notification->pid = $result["pid"];
                 $notification->payload = $result["payload"];
-                $listeners[$channel]->yield($notification);
+                $listeners[$channel]->emit($notification);
             }
 
             if ($deferred === null) {
diff --git a/src/PqHandle.php b/src/PqHandle.php
index 0edc7e5..86bb44c 100644
--- a/src/PqHandle.php
+++ b/src/PqHandle.php
@@ -481,7 +481,7 @@ final class PqHandle implements Handle
                         $notification->channel = $channel;
                         $notification->pid = $pid;
                         $notification->payload = $message;
-                        $source->yield($notification);
+                        $source->emit($notification);
                     }
                 );
             } catch (\Throwable $exception) {