当前位置：刘世明的博客 > blockchain > ethereum > 正文

go subscribe new block

2021-05-24 分类：ethereum / go / snippet 阅读(2483) 评论(2)

func TestSubscribeNewBlock(t *testing.T) {
    client, err := ethclient.DialContext(context.Background(), "ws://10.136.0.32:9546")
    if err != nil {
        t.Fatal(err)
    }
    ch := make(chan *types.Header)
    sub, err := client.SubscribeNewHead(context.Background(), ch)
    if err != nil {
        t.Fatal(err)
    }
    for {
        select {
        case header := <-ch:
            t.Log(header.Number)
        case err = <-sub.Err():
            if err != nil {
                t.Error(err.Error())
            }
            return
        }
    }
}