Merge pull request #55 from ipfs/kevina/buf-size-match

Make sure buffer size of wrapper datastores match underlying datastore.

keytransform/keytransform.go

@@ -60,7 +60,7 @@ func (d *ktds) Query(q dsq.Query) (dsq.Results, error) {
 		return nil, err
 	}
 
-	ch := make(chan dsq.Result)
+	ch := make(chan dsq.Result, cap(qr.Next()))
 	go func() {
 		defer close(ch)
 		defer qr.Close()

namespace/namespace.go

@@ -58,12 +58,7 @@ func (d *datastore) Query(q dsq.Query) (dsq.Results, error) {
 		return nil, err
 	}
 
-	var ch chan dsq.Result
-	if q.KeysOnly {
-		ch = make(chan dsq.Result, dsq.KeysOnlyBufSize)
-	} else {
-		ch = make(chan dsq.Result)
-	}
+	ch := make(chan dsq.Result, cap(qr.Next()))
 
 	go func() {
 		defer close(ch)