Channel implements the [Client.Channel] interface method.
()
| 108 | |
| 109 | // Channel implements the [Client.Channel] interface method. |
| 110 | func (c *DefaultClient) Channel() chan Message { |
| 111 | c.mu.RLock() |
| 112 | defer c.mu.RUnlock() |
| 113 | |
| 114 | return c.channel |
| 115 | } |
| 116 | |
| 117 | // Subscriptions implements the [Client.Subscriptions] interface method. |
| 118 | // |
no outgoing calls