ChannelSize is like Channel, but creates a Go channel with specified buffer size. Deprecated: use Channel(WithChannelSize(size)), remove in v9.
(size int)
| 586 | // |
| 587 | // Deprecated: use Channel(WithChannelSize(size)), remove in v9. |
| 588 | func (c *PubSub) ChannelSize(size int) <-chan *Message { |
| 589 | return c.Channel(WithChannelSize(size)) |
| 590 | } |
| 591 | |
| 592 | // ChannelWithSubscriptions is like Channel, but message type can be either |
| 593 | // *Subscription or *Message. Subscription messages can be used to detect |
nothing calls this directly
no test coverage detected