111
// NewCollection creates a new collection. For subscriptions to work, you must call Start/Stop.
112
// Get will work without Start/Stop.
114
>
// Do this at the first convenient place we have a logger:
115
>
logSharedStructureWarnings(logger)
116
>
117
>
return &Collection{
118
>
client: client,
119
>
logger: logger,
120
>
errCount: -1,
121
>
subscriptions: make(map[Key]map[int]any),
122
>
convertCache: new(sync.Map),
123
>
indexCache: new(sync.Map),
124
>
}
125
>
}
126
127
func (c *Collection) Start() {