()
| 55 | } |
| 56 | |
| 57 | func (c *PubSub) String() string { |
| 58 | c.mu.Lock() |
| 59 | defer c.mu.Unlock() |
| 60 | |
| 61 | channels := slices.Collect(maps.Keys(c.channels)) |
| 62 | channels = append(channels, slices.Collect(maps.Keys(c.patterns))...) |
| 63 | channels = append(channels, slices.Collect(maps.Keys(c.schannels))...) |
| 64 | return fmt.Sprintf("PubSub(%s)", strings.Join(channels, ", ")) |
| 65 | } |
| 66 | |
| 67 | func (c *PubSub) connWithLock(ctx context.Context) (*pool.Conn, error) { |
| 68 | c.mu.Lock() |