Add interrupt support for outbound groups

2026-10-02 20:36:40 +00:00 · 2023-09-15 19:09:03 +08:00
parent 274a147e89
commit 09cf71cc2d
10 changed files with 282 additions and 55 deletions
@@ -0,0 +1,13 @@
+package interrupt
+
+import "context"
+
+type contextKeyIsExternalConnection struct{}
+
+func ContextWithIsExternalConnection(ctx context.Context) context.Context {
+	return context.WithValue(ctx, contextKeyIsExternalConnection{}, true)
+}
+
+func IsExternalConnectionFromContext(ctx context.Context) bool {
+	return ctx.Value(contextKeyIsExternalConnection{}) != nil
+}