eth_subscribe

Protocol: WebSocket (WSS) only

Description

Subscribe to real-time events over WebSocket (newHeads, logs, newPendingTransactions).

Parameters

Parameter	Type	Required	Description
subscriptionType	string	Yes	Event type

Request

{
  "jsonrpc": "2.0",
  "method": "eth_subscribe",
  "params": [
    "newHeads"
  ],
  "id": 1
}

Code Examples

cURL

curl -X POST https://eth-mainnet.blockreq.com/v1/rpc/public \
  -H "Content-Type: application/json" \
  -d '{"jsonrpc":"2.0","method":"eth_subscribe","params":["newHeads"],"id":1}'

TypeScript

const response = await fetch("https://eth-mainnet.blockreq.com/v1/rpc/public", {
  method: "POST",
  headers: { "Content-Type": "application/json" },
  body: JSON.stringify({
  "jsonrpc": "2.0",
  "method": "eth_subscribe",
  "params": [
    "newHeads"
  ],
  "id": 1
}),
});
const data = await response.json();
console.log(data.result);

Python

import requests

response = requests.post(
    "https://eth-mainnet.blockreq.com/v1/rpc/public",
    json={
    "jsonrpc": "2.0",
    "method": "eth_subscribe",
    "params": [
        "newHeads"
    ],
    "id": 1
}
)
print(response.json()["result"])

Go

package main

import (
  "bytes"
  "encoding/json"
  "fmt"
  "io"
  "net/http"
)

func main() {
  payload := []byte(`{"jsonrpc":"2.0","method":"eth_subscribe","params":["newHeads"],"id":1}`)
  resp, err := http.Post(
    "https://eth-mainnet.blockreq.com/v1/rpc/public",
    "application/json",
    bytes.NewBuffer(payload),
  )
  if err != nil {
    panic(err)
  }
  defer resp.Body.Close()

  body, _ := io.ReadAll(resp.Body)
  var result map[string]interface{}
  json.Unmarshal(body, &result)
  fmt.Println(result["result"])
}

Try It