143
readerOptions := options.ReaderOptions // make a copy
144
if readerID != DefaultReaderId {
146
>
// otherwise those readers will keep loading, hit pending task count limit, unload, throttle, load, etc...
147
>
// use a limit lower than the critical pending task count instead
148
>
//
149
>
// Use lower maxPendingTaskCount for lower reader to guarantee that higher reader can
150
>
// always have some tasks loaded.
151
>
readerOptions.MaxPendingTasksCount = func() int {
152
return min(
153
options.MaxPendingTasksCount(),