"unsafe"
"github.com/RoaringBitmap/roaring"
+ "github.com/anacrolix/chansync/events"
"github.com/anacrolix/log"
"github.com/anacrolix/missinggo/v2/bitmap"
- "github.com/anacrolix/chansync"
request_strategy "github.com/anacrolix/torrent/request-strategy"
)
func (cl *Client) requester() {
for {
- update := func() chansync.Signaled {
+ update := func() events.Signaled {
cl.lock()
defer cl.unlock()
cl.doRequests()