bitswap.go

func (bs *bitswap) taskWorker(ctx context.Context) {
	log := log.Prefix("bitswap(%s).taskWorker", bs.self)
	for {
		select {
		case <-ctx.Done():
			log.Debugf("exiting")
			return
		case nextEnvelope := <-bs.engine.Outbox():
			select {
			case <-ctx.Done():
				return
			case envelope := <-nextEnvelope:
				bs.send(ctx, envelope.Peer, envelope.Message)
			}
		}
	}
}