cosmos

Documentation

Index

• func BlockStream(ctx context.Context, c *http.HTTP) <-chan block.WithTxs
• func Subscribe(ctx context.Context, client *http.HTTP) (<-chan block.TmBlock, <-chan block.TxStatus, error)

Functions

func BlockStream

func BlockStream(ctx context.Context, c *http.HTTP) <-chan block.WithTxs

BlockStream returns read-only channel of completed blocks

func Subscribe

func Subscribe(ctx context.Context, client *http.HTTP) (<-chan block.TmBlock, <-chan block.TxStatus, error)

Subscribe dials tendermint rpc and returns two streams, one for committed blocks, one for transactions that occurred