diff options
| author |  tobi <31960611+tsmethurst@users.noreply.github.com> | 2024-09-16 11:06:00 +0200 |
|---|---|---|
| committer |  GitHub <noreply@github.com> | 2024-09-16 09:06:00 +0000 |
| commit | b2572b9e074ebbce8bcf1b9979d4d8ea066650d6 (patch) | |
| tree | 0c2a08ed63b582676ce7661252a6917db751c62a /vendor/google.golang.org/grpc/internal/grpcsync/pubsub.go | |
| parent | [chore]: Bump golang.org/x/net from 0.28.0 to 0.29.0 (#3303) (diff) | |
| download | gotosocial-b2572b9e074ebbce8bcf1b9979d4d8ea066650d6.tar.xz | |
[chore] Bump otel deps -> v1.30.0/v0.52.0 (#3307)
Diffstat (limited to 'vendor/google.golang.org/grpc/internal/grpcsync/pubsub.go')
| -rw-r--r-- | vendor/google.golang.org/grpc/internal/grpcsync/pubsub.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/vendor/google.golang.org/grpc/internal/grpcsync/pubsub.go b/vendor/google.golang.org/grpc/internal/grpcsync/pubsub.go index aef8cec1a..6d8c2f518 100644 --- a/vendor/google.golang.org/grpc/internal/grpcsync/pubsub.go +++ b/vendor/google.golang.org/grpc/internal/grpcsync/pubsub.go @@ -77,7 +77,7 @@ func (ps *PubSub) Subscribe(sub Subscriber) (cancel func()) { if ps.msg != nil { msg := ps.msg - ps.cs.Schedule(func(context.Context) { + ps.cs.TrySchedule(func(context.Context) { ps.mu.Lock() defer ps.mu.Unlock() if !ps.subscribers[sub] { @@ -103,7 +103,7 @@ func (ps *PubSub) Publish(msg any) { ps.msg = msg for sub := range ps.subscribers { s := sub - ps.cs.Schedule(func(context.Context) { + ps.cs.TrySchedule(func(context.Context) { ps.mu.Lock() defer ps.mu.Unlock() if !ps.subscribers[s] { |