(cn *pool.Conn)
| 618 | } |
| 619 | |
| 620 | func (c *PubSub) pushNotificationHandlerContext(cn *pool.Conn) push.NotificationHandlerContext { |
| 621 | // PubSub doesn't have a client or connection pool, so we pass nil for those |
| 622 | // PubSub connections are blocking |
| 623 | return push.NotificationHandlerContext{ |
| 624 | PubSub: c, |
| 625 | Conn: cn, |
| 626 | IsBlocking: true, |
| 627 | } |
| 628 | } |
| 629 | |
| 630 | type ChannelOption func(c *channel) |
| 631 |
no outgoing calls
no test coverage detected