From 94e9d3a2a87c667b607da284b041a7520f3a1c2a Mon Sep 17 00:00:00 2001
From: a <a@tuxpa.in>
Date: Mon, 17 Feb 2025 17:32:48 -0600
Subject: [PATCH] expose notifier id
---
contrib/extension/subscription/subscription.go | 4 ++++
1 file changed, 4 insertions(+)
diff --git a/contrib/extension/subscription/subscription.go b/contrib/extension/subscription/subscription.go
index bd9159a..acaef9c 100644
--- a/contrib/extension/subscription/subscription.go
+++ b/contrib/extension/subscription/subscription.go
@@ -92,6 +92,10 @@ type Notifier struct {
err chan error
}
+func (n *Notifier) ID() SubID {
+ return n.id
+}
+
// Notify sends a notification to the client with the given data as payload.
// If an error occurs the RPC connection is closed and the error is returned.
func (n *Notifier) Notify(data any) error {
--
GitLab