forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-08-20 10:52:25 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Various fixes to client_example_test.go so it actually runs

Browse source
This commit is contained in:
Julian Y 2019-04-20 01:23:56 -07:00 committed by Felix Lange
parent 40283d0522
commit e3c4733a1c
1 changed files with 21 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

25
rpc/client_example_test.go
View file

@ -1,4 +1,4 @@
// Copyright 2016 The go-ethereum Authors // Copyright 2019 The go-ethereum Authors
// This file is part of the go-ethereum library. // This file is part of the go-ethereum library.
// //
// The go-ethereum library is free software: you can redistribute it and/or modify // The go-ethereum library is free software: you can redistribute it and/or modify
@ -18,6 +18,7 @@ package rpc_test
import ( import (
"context" "context"
"encoding/json"
"fmt" "fmt"
"math/big" "math/big"
"time" "time"
@ -31,11 +32,27 @@ import (
// eth_getBlockByNumber("latest", {}) // eth_getBlockByNumber("latest", {})
// returns the latest block object. // returns the latest block object.
// //
// eth_subscribe("newBlocks") // eth_subscribe("newHeads")
// creates a subscription which fires block objects when new blocks arrive. // creates a subscription which fires block objects when new blocks arrive.
type Block struct { type Block struct {
Number *big.Int Number *BigInt
}
type BigInt struct {
big.Int
}
func (i *BigInt) UnmarshalJSON(b []byte) error {
var val string
err := json.Unmarshal(b, &val)
if err != nil {
return err
}
i.SetString(val[2:], 16)
return nil
} }
func ExampleClientSubscription() { func ExampleClientSubscription() {
@ -75,7 +92,7 @@ func subscribeBlocks(client *rpc.Client, subch chan Block) {
// The connection is established now. // The connection is established now.
// Update the channel with the current block. // Update the channel with the current block.
var lastBlock Block var lastBlock Block
if err := client.CallContext(ctx, &lastBlock, "eth_getBlockByNumber", "latest"); err != nil { if err := client.CallContext(ctx, &lastBlock, "eth_getBlockByNumber", "latest", false); err != nil {
fmt.Println("can't get latest block:", err) fmt.Println("can't get latest block:", err)
return return
} }