Function onNotification

packages/sql-pg/src/PgClient.ts:364–368

(msg: Pg.Notification)

          Stream.asyncPush<string, SqlError>(Effect.fnUntraced(function*(emit) {
            const client = yield* RcRef.get(listenClient)
            function onNotification(msg: Pg.Notification) {
              if (msg.channel === channel && msg.payload) {
                emit.single(msg.payload)
              }
            }
            yield* Effect.addFinalizer(() =>
              Effect.promise(() => {
                client.off("notification", onNotification)