rpc: use any

This commit is contained in:
Felix Lange 2023-10-31 12:24:15 +01:00
parent 416485400c
commit 4180b5d442

View file

@ -105,7 +105,7 @@ type Notifier struct {
mu sync.Mutex mu sync.Mutex
sub *Subscription sub *Subscription
buffer []interface{} buffer []any
callReturned bool callReturned bool
activated bool activated bool
} }
@ -129,7 +129,7 @@ func (n *Notifier) CreateSubscription() *Subscription {
// Notify sends a notification to the client with the given data as payload. // 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. // If an error occurs the RPC connection is closed and the error is returned.
func (n *Notifier) Notify(id ID, data interface{}) error { func (n *Notifier) Notify(id ID, data any) error {
n.mu.Lock() n.mu.Lock()
defer n.mu.Unlock() defer n.mu.Unlock()