Badger: Subscription working code

main.go

package main

import (
	"context"
	"fmt"
	"log"
	"time"

	badger "github.com/dgraph-io/badger/v2"
	"github.com/dgraph-io/badger/v2/pb"
)

func main() {
	log.Println("starting")

	db, err := badger.Open(badger.DefaultOptions("./p"))
	if err != nil {
		log.Fatal(err)
	}
	defer db.Close()
	// Your code here…

	ctx := context.Background()

	handleSubscription := func(kvl *pb.KVList) error {
		panic("AAAAAAAHHH")
		for _, kv := range kvl.GetKv() {
			fmt.Println(string(kv.GetKey()), string(kv.GetValue()))
		}
		return nil
	}

	go func() {
		// It is important that the prefix is not nil.
		if err := db.Subscribe(ctx, handleSubscription, []byte("f")); err != nil {
			fmt.Println(err)
		}
	}()

	log.Println("opened?")

	// Insert some data
	txn := db.NewTransaction(true)
	txn.Set([]byte("foo"), []byte("bar"))
	if err := txn.Commit(); err != nil {
		panic(err)
	}
	log.Println("commit done")

	// Wait for a second.
	time.Sleep(time.Second * 1)
}