watchBlocks

Watches and returns information for incoming blocks.

Usage

Pass through your Public Client, along with a listener.

import { publicClient } from './client'
 
const unwatch = publicClient.watchBlocks( 
  { onBlock: block => console.log(block) }
)
/**
 * > {
 *  baseFeePerGas: 10789405161n,
 *  difficulty: 11569232145203128n,
 *  extraData: '0x75732d656173742d38',
 *  ...
 * }
 * 
 * > {
 *  baseFeePerGas: 12394051511n,
 *  difficulty: 11512315412421123n,
 *  extraData: '0x5123ab1512dd14aa',
 *  ...
 * }
 */

Returns

UnwatchFn

A function that can be invoked to stop watching for new blocks.

Parameters

onBlock

• Type: (block: Block) => void

The block information.

const unwatch = publicClient.watchBlocks(
  { onBlock: block => console.log(block) } 
)

onError (optional)

• Type: (error: Error) => void

Error thrown from getting a block.

const unwatch = publicClient.watchBlocks(
  { 
    onBlock: block => console.log(block),
    onError: error => console.log(error) 
  }
)

blockTag (optional)

• Type: 'latest' | 'earliest' | 'pending' | 'safe' | 'finalized'
• Default: 'latest'

Watch for new blocks on a given tag.

const unwatch = publicClient.watchBlocks(
  { 
    blockTag: 'safe',
    onBlock: block => console.log(block), 
  }
)

emitMissed (optional)

• Type: boolean
• Default: false

Whether or not to emit missed blocks to the callback.

Missed blocks may occur in instances where internet connection is lost, or the block time is lesser than the polling interval of the client.

const unwatch = publicClient.watchBlocks(
  { 
    emitMissed: true, 
    onBlock: block => console.log(block),
  }
)

emitOnBegin (optional)

• Type: boolean
• Default: false

Whether or not to emit the block to the callback when the subscription opens.

const unwatch = publicClient.watchBlocks(
  { 
    emitOnBegin: true, 
    onBlock: block => console.log(block),
  }
)

includeTransactions (optional)

• Type: boolean

Whether or not to include transactions (as a structured array of Transaction objects).

const unwatch = publicClient.watchBlocks(
  { 
    includeTransactions: true,  
    onBlock: block => console.log(block),
  }
)

poll (optional)

• Type: boolean
• Default: false for WebSocket Clients, true for non-WebSocket Clients

Whether or not to use a polling mechanism to check for new blocks instead of a WebSocket subscription.

This option is only configurable for Clients with a WebSocket Transport.

import { createPublicClient, webSocket } from 'viem'
import { mainnet } from 'viem/chains'
 
const publicClient = createPublicClient({
  chain: mainnet,
  transport: webSocket()
})
 
const unwatch = publicClient.watchBlocks(
  { 
    onBlock: block => console.log(block),
    poll: true, 
  }
)

pollingInterval (optional)

• Type: number

Polling frequency (in ms). Defaults to the Client's pollingInterval config.

const unwatch = publicClient.watchBlocks(
  { 
    onBlock: block => console.log(block),
    pollingInterval: 1_000, 
  }
)

Example

Check out the usage of watchBlocks in the live Watch Blocks Example below.

JSON-RPC Methods

• When poll: true, calls eth_getBlockByNumber on a polling interval.
• When poll: false & WebSocket Transport, uses a WebSocket subscription via eth_subscribe and the "newHeads" event.