type github.com/gotd/td/telegram.CloseInvoker

33 uses

	github.com/gotd/td/telegram (current package)
		cdn_pool_manager.go#L15: 	conn CloseInvoker
		cdn_pool_manager.go#L30: 	conn    CloseInvoker
		cdn_pool_manager.go#L34: var _ CloseInvoker = (*cdnPoolHandle)(nil)
		cdn_pool_manager.go#L58: 	refs map[CloseInvoker]int
		cdn_pool_manager.go#L63: 	closing map[CloseInvoker]bool
		cdn_pool_manager.go#L68: 	closeQueue   []CloseInvoker
		cdn_pool_manager.go#L69: 	closePending []CloseInvoker
		cdn_pool_manager.go#L85: 		refs:    map[CloseInvoker]int{},
		cdn_pool_manager.go#L86: 		closing: map[CloseInvoker]bool{},
		cdn_pool_manager.go#L102: func pickCDNPool(pools []cachedCDNPool, need int64) (CloseInvoker, bool) {
		cdn_pool_manager.go#L128: func (m *cdnPoolManager) cachedHandleLocked(conn CloseInvoker) CloseInvoker {
		cdn_pool_manager.go#L143: func (m *cdnPoolManager) releaseCachedHandle(conn CloseInvoker) bool {
		cdn_pool_manager.go#L161: func (m *cdnPoolManager) acquire(dc int, need int64) (CloseInvoker, bool) {
		cdn_pool_manager.go#L172: func (m *cdnPoolManager) publishOrAcquire(dc int, need int64, created CloseInvoker) (CloseInvoker, bool) {
		cdn_pool_manager.go#L186: func (m *cdnPoolManager) drain() []CloseInvoker {
		cdn_pool_manager.go#L190: 	seen := map[CloseInvoker]struct{}{}
		cdn_pool_manager.go#L191: 	cdnConns := make([]CloseInvoker, 0, len(m.conns)+len(m.closeQueue)+len(m.closePending))
		cdn_pool_manager.go#L192: 	add := func(conn CloseInvoker) {
		cdn_pool_manager.go#L214: 	m.refs = map[CloseInvoker]int{}
		cdn_pool_manager.go#L215: 	m.closing = map[CloseInvoker]bool{}
		cdn_pool_manager.go#L240: func (m *cdnPoolManager) enqueueCloseLocked(stale []CloseInvoker) {
		cdn_pool_manager.go#L310: 	toClose := make([]CloseInvoker, 0, len(stale))
		client.go#L110: 	subConns    map[int]CloseInvoker
		client.go#L272: 	c.subConns = map[int]CloseInvoker{}
		connect.go#L175: 		subConns := make([]CloseInvoker, 0, len(c.subConns))
		connect.go#L179: 		c.subConns = map[int]CloseInvoker{}
		pool.go#L21: type CloseInvoker interface {
		pool.go#L42: func (c *Client) Pool(max int64) (CloseInvoker, error) {
		pool.go#L195: func (c *Client) DC(ctx context.Context, dc int, max int64) (CloseInvoker, error) {
		pool.go#L201: func (c *Client) MediaOnly(ctx context.Context, dc int, max int64) (CloseInvoker, error) {
		pool.go#L209: func (c *Client) CDN(ctx context.Context, dc int, max int64) (CloseInvoker, error) {