File tree Expand file tree Collapse file tree 1 file changed +4
-5
lines changed Expand file tree Collapse file tree 1 file changed +4
-5
lines changed Original file line number Diff line number Diff line change @@ -28,7 +28,6 @@ import (
28
28
"github.com/golang/protobuf/proto"
29
29
"github.com/stretchr/testify/require"
30
30
31
- "github.com/dgraph-io/badger/v4/pb"
32
31
bpb "github.com/dgraph-io/badger/v4/pb"
33
32
"github.com/dgraph-io/badger/v4/y"
34
33
"github.com/dgraph-io/ristretto/z"
@@ -295,18 +294,18 @@ func TestStreamCustomKeyToList(t *testing.T) {
295
294
296
295
stream := db .NewStreamAt (math .MaxUint64 )
297
296
stream .LogPrefix = "Testing"
298
- stream .KeyToList = func (key []byte , itr * Iterator ) (* pb .KVList , error ) {
297
+ stream .KeyToList = func (key []byte , itr * Iterator ) (* bpb .KVList , error ) {
299
298
item := itr .Item ()
300
299
val , err := item .ValueCopy (nil )
301
300
if err != nil {
302
301
return nil , err
303
302
}
304
- kv := & pb .KV {
303
+ kv := & bpb .KV {
305
304
Key : y .Copy (item .Key ()),
306
305
Value : val ,
307
306
}
308
- return & pb .KVList {
309
- Kv : []* pb .KV {kv },
307
+ return & bpb .KVList {
308
+ Kv : []* bpb .KV {kv },
310
309
}, nil
311
310
}
312
311
res := map [string ]struct {}{"p0" : {}, "p1" : {}, "p2" : {}}
You can’t perform that action at this time.
0 commit comments