Function onNotification

packages/sql/pg/src/PgClient.ts:624–628

(msg: Pg.Notification)

        Stream.callback<string, SqlError>(Effect.fnUntraced(function*(queue) {
          const client = yield* options.listenAcquirer
          function onNotification(msg: Pg.Notification) {
            if (msg.channel === channel && msg.payload) {
              Queue.offerUnsafe(queue, msg.payload)
            }
          }
          yield* Effect.addFinalizer(() =>
            Effect.promise(() => {
              client.off("notification", onNotification)