3pp-mirror/pomerium
1
0
Fork 0
mirror of https://github.com/pomerium/pomerium.git synced 2025-08-06 10:21:05 +02:00
Code Issues Projects Releases Packages Wiki Activity

use cancel cause

Browse source
This commit is contained in:
Caleb Doxsey 2023-11-01 12:10:18 -06:00
parent 23366129fa
commit d1350f0447
1 changed files with 4 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

7
internal/events/target.go
View file

@ -2,6 +2,7 @@ package events
import ( import (
"context" "context"
"errors"
"sync" "sync"
"github.com/google/uuid" "github.com/google/uuid"
@ -47,7 +48,7 @@ type (
type Target[T any] struct { type Target[T any] struct {
initOnce sync.Once initOnce sync.Once
ctx context.Context ctx context.Context
cancel context.CancelFunc cancel context.CancelCauseFunc
addListenerCh chan addListenerEvent[T] addListenerCh chan addListenerEvent[T]
removeListenerCh chan removeListenerEvent[T] removeListenerCh chan removeListenerEvent[T]
dispatchCh chan dispatchEvent[T] dispatchCh chan dispatchEvent[T]
@ -74,7 +75,7 @@ func (t *Target[T]) AddListener(listener Listener[T]) Handle {
func (t *Target[T]) Close() { func (t *Target[T]) Close() {
t.init() t.init()
t.cancel() t.cancel(errors.New("target closed"))
} }
// Dispatch dispatches an event to any listeners. // Dispatch dispatches an event to any listeners.
@ -99,7 +100,7 @@ func (t *Target[T]) RemoveListener(handle Handle) {
func (t *Target[T]) init() { func (t *Target[T]) init() {
t.initOnce.Do(func() { t.initOnce.Do(func() {
t.ctx, t.cancel = context.WithCancel(context.Background()) t.ctx, t.cancel = context.WithCancelCause(context.Background())
t.addListenerCh = make(chan addListenerEvent[T], 1) t.addListenerCh = make(chan addListenerEvent[T], 1)
t.removeListenerCh = make(chan removeListenerEvent[T], 1) t.removeListenerCh = make(chan removeListenerEvent[T], 1)
t.dispatchCh = make(chan dispatchEvent[T], 1) t.dispatchCh = make(chan dispatchEvent[T], 1)