Tendermint subscribe example

main.go

package main

import (
	"context"
	"encoding/json"
	"fmt"
	rpchttp "github.com/tendermint/tendermint/rpc/client/http"
	"github.com/tendermint/tendermint/types"
	"time"
)

func main() {
	client, _ := rpchttp.New("tcp://127.0.0.1:26657", "/websocket")
	err := client.Start()
	if err != nil {
		panic(err)
	}
	defer client.Stop()
	ctx, cancel := context.WithTimeout(context.Background(), 1*time.Second)
	defer cancel()
	query := "tm.event = 'Tx'"
	event, err := client.Subscribe(ctx, "test-client", query)
	if err != nil {
		panic(err)
	}

	func() {
		for e := range event {
			tx := e.Data.(types.EventDataTx)
			j, _ := json.MarshalIndent(json.RawMessage(tx.TxResult.Result.Log), "", "  ")
			fmt.Println(string(j))
		}
	}()
}