fluencelabs/go-libp2p-kad-dht
1
0
Fork 0
mirror of https://github.com/fluencelabs/go-libp2p-kad-dht synced 2025-07-31 03:52:03 +00:00
Code Issues Projects Releases Wiki Activity

SearchValue: add backward-compatible GetValues

Browse Source
This commit is contained in:
Łukasz Magiera
2018-07-18 19:25:07 +02:00
parent 547c0a7170
commit e28b133f80
2 changed files with 62 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
routing.go
View File

@@ -226,6 +226,20 @@ func (dht *IpfsDHT) SearchValue(ctx context.Context, key string, opts ...ropts.O
}
// GetValues gets nvals values corresponding to the given key.
func (dht *IpfsDHT) GetValues(ctx context.Context, key string, nvals int) (_ []RecvdVal, err error) {
valCh, err := dht.getValues(ctx, key, nvals)
if err != nil {
return nil, err
}
out := make([]RecvdVal, 0, nvals)
for val := range valCh {
out = append(out, val)
}
return out, nil
}
func (dht *IpfsDHT) getValues(ctx context.Context, key string, nvals int) (<-chan RecvdVal, error) {
eip := log.EventBegin(ctx, "GetValues")