counter.go

package main

import (
	"context"
	"encoding/binary"
	"fmt"
	"time"

	rpcclient "github.com/tendermint/tendermint/rpc/lib/client"
	cmn "github.com/tendermint/tmlibs/common"
)

func main() {
	wsc := rpcclient.NewWSClient("127.0.0.1:46657", "/websocket")
	err := wsc.Start()
	if err != nil {
		cmn.Exit(err.Error())
	}
	defer wsc.Stop()

	// Read a bunch of responses
	go func() {
		for {
			_, ok := <-wsc.ResponsesCh
			if !ok {
				break
			}
			//fmt.Println("Received response", string(wire.JSONBytes(res)))
		}
	}()

	// Make a bunch of requests
	buf := make([]byte, 32)
	for i := 0; ; i++ {
		binary.BigEndian.PutUint64(buf, uint64(i))
		//txBytes := hex.EncodeToString(buf[:n])
		fmt.Print(".")
		err = wsc.Call(context.TODO(), "broadcast_tx", map[string]interface{}{"tx": buf[:8]})
		if err != nil {
			cmn.Exit(err.Error())
		}
		if i%1000 == 0 {
			fmt.Println(i)
		}
		time.Sleep(time.Microsecond * 1000)
	}
}