Commit f8a09c9b authored by EvanJRichard's avatar EvanJRichard

Make waitForBlockTag private.

parent d71a0fb8
...@@ -107,15 +107,15 @@ func WaitForBlock(number *big.Int, client *ethclient.Client, timeout time.Durati ...@@ -107,15 +107,15 @@ func WaitForBlock(number *big.Int, client *ethclient.Client, timeout time.Durati
} }
func WaitForBlockToBeFinalized(number *big.Int, client *ethclient.Client, timeout time.Duration) (*types.Block, error) { func WaitForBlockToBeFinalized(number *big.Int, client *ethclient.Client, timeout time.Duration) (*types.Block, error) {
return WaitForBlockTag(number, client, timeout, int64(rpc.FinalizedBlockNumber)) return waitForBlockTag(number, client, timeout, int64(rpc.FinalizedBlockNumber))
} }
func WaitForBlockToBeSafe(number *big.Int, client *ethclient.Client, timeout time.Duration) (*types.Block, error) { func WaitForBlockToBeSafe(number *big.Int, client *ethclient.Client, timeout time.Duration) (*types.Block, error) {
return WaitForBlockTag(number, client, timeout, int64(rpc.SafeBlockNumber)) return waitForBlockTag(number, client, timeout, int64(rpc.SafeBlockNumber))
} }
// WaitForBlockTag polls for a block number to reach the specified tag & then returns that block at the number. // waitForBlockTag polls for a block number to reach the specified tag & then returns that block at the number.
func WaitForBlockTag(number *big.Int, client *ethclient.Client, timeout time.Duration, tag rpc.BlockNumber) (*types.Block, error) { func waitForBlockTag(number *big.Int, client *ethclient.Client, timeout time.Duration, tag rpc.BlockNumber) (*types.Block, error) {
timeoutCh := time.After(timeout) timeoutCh := time.After(timeout)
ctx, cancel := context.WithTimeout(context.Background(), timeout) ctx, cancel := context.WithTimeout(context.Background(), timeout)
defer cancel() defer cancel()
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment