diff --git a/blocks/blockstore/blockstore.go b/blocks/blockstore/blockstore.go
index dc94dbc6fc60bf92c6ee50ab83c2ff75aa4b82fa..7e929af10355b6399175f64544c0d5d7ba68b251 100644
--- a/blocks/blockstore/blockstore.go
+++ b/blocks/blockstore/blockstore.go
@@ -31,7 +31,6 @@ type Blockstore interface {
 	Get(u.Key) (*blocks.Block, error)
 	Put(*blocks.Block) error
 
-	AllKeys(ctx context.Context) ([]u.Key, error)
 	AllKeysChan(ctx context.Context) (<-chan u.Key, error)
 }
 
@@ -82,24 +81,6 @@ func (s *blockstore) DeleteBlock(k u.Key) error {
 	return s.datastore.Delete(k.DsKey())
 }
 
-// AllKeys runs a query for keys from the blockstore.
-// this is very simplistic, in the future, take dsq.Query as a param?
-//
-// AllKeys respects context
-func (bs *blockstore) AllKeys(ctx context.Context) ([]u.Key, error) {
-
-	ch, err := bs.AllKeysChan(ctx)
-	if err != nil {
-		return nil, err
-	}
-
-	var keys []u.Key
-	for k := range ch {
-		keys = append(keys, k)
-	}
-	return keys, nil
-}
-
 // AllKeysChan runs a query for keys from the blockstore.
 // this is very simplistic, in the future, take dsq.Query as a param?
 //
diff --git a/blocks/blockstore/blockstore_test.go b/blocks/blockstore/blockstore_test.go
index 4daed126d8b2a4f491181dc574bd0c349f3daf0f..51f5aad11aa61a9fdafedde090348cc225a8b295 100644
--- a/blocks/blockstore/blockstore_test.go
+++ b/blocks/blockstore/blockstore_test.go
@@ -63,14 +63,24 @@ func newBlockStoreWithKeys(t *testing.T, d ds.Datastore, N int) (Blockstore, []u
 	return bs, keys
 }
 
+func collect(ch <-chan u.Key) []u.Key {
+	var keys []u.Key
+	for k := range ch {
+		keys = append(keys, k)
+	}
+	return keys
+}
+
 func TestAllKeysSimple(t *testing.T) {
 	bs, keys := newBlockStoreWithKeys(t, nil, 100)
 
 	ctx := context.Background()
-	keys2, err := bs.AllKeys(ctx)
+	ch, err := bs.AllKeysChan(ctx)
 	if err != nil {
 		t.Fatal(err)
 	}
+	keys2 := collect(ch)
+
 	// for _, k2 := range keys2 {
 	// 	t.Log("found ", k2.Pretty())
 	// }
@@ -90,10 +100,11 @@ func TestAllKeysRespectsContext(t *testing.T) {
 
 	getKeys := func(ctx context.Context) {
 		started <- struct{}{}
-		_, err := bs.AllKeys(ctx) // once without cancelling
+		ch, err := bs.AllKeysChan(ctx) // once without cancelling
 		if err != nil {
 			errors <- err
 		}
+		_ = collect(ch)
 		done <- struct{}{}
 		errors <- nil // a nil one to signal break
 	}
diff --git a/blocks/blockstore/write_cache.go b/blocks/blockstore/write_cache.go
index b60a4d2c223cad31733842c90546f33ab2f698b4..a1399fcc68b7ddb0a83da4ded6c37f89c5b54b5f 100644
--- a/blocks/blockstore/write_cache.go
+++ b/blocks/blockstore/write_cache.go
@@ -45,10 +45,6 @@ func (w *writecache) Put(b *blocks.Block) error {
 	return w.blockstore.Put(b)
 }
 
-func (w *writecache) AllKeys(ctx context.Context) ([]u.Key, error) {
-	return w.blockstore.AllKeys(ctx)
-}
-
 func (w *writecache) AllKeysChan(ctx context.Context) (<-chan u.Key, error) {
 	return w.blockstore.AllKeysChan(ctx)
 }