(ctx context.Context, cid cid.Cid, count int)
| 65 | } |
| 66 | |
| 67 | func (c *Composer) FindProvidersAsync(ctx context.Context, cid cid.Cid, count int) <-chan peer.AddrInfo { |
| 68 | log.Debug("composer: calling findProvidersAsync: ", cid) |
| 69 | return c.FindProvidersRouter.FindProvidersAsync(ctx, cid, count) |
| 70 | } |
| 71 | |
| 72 | func (c *Composer) FindPeer(ctx context.Context, pid peer.ID) (peer.AddrInfo, error) { |
| 73 | log.Debug("composer: calling findPeer: ", pid) |
no outgoing calls