eth-v1-events RPC Method

Parameters

topics

array[string]

Loading...

Returns

data

Loading...

slot

string

Loading...

block

string

Loading...

state

string

Loading...

current_duty_dependent_root

string

Loading...

previous_duty_dependent_root

string

Loading...

epoch_transition

boolean

Loading...

execution_optimistic

boolean

Loading...

Request

1
curl -X GET \
2
    "https://docs-demo.xdai.quiknode.pro/eth/v1/events?topics=head" \
3
    -H "accept: text/event-stream"

1
curl -X GET \
2
    "https://docs-demo.xdai.quiknode.pro/eth/v1/events?topics=head" \
3
    -H "accept: text/event-stream"

1
const EventSource = require("eventsource");
2

3
let url = "https://docs-demo.xdai.quiknode.pro/eth/v1/events?topics=head"
4
let eventSourceInitDict = {headers: {'Accept': 'text/event-stream'}};
5

6
async function main() {
7
  let es = new EventSource(url, eventSourceInitDict);
8

9
  es.addEventListener('head', function (e) {
10
      console.log(e.data)
11
  })
12
}
13

14
main();

1
const EventSource = require("eventsource");
2

3
let url = "https://docs-demo.xdai.quiknode.pro/eth/v1/events?topics=head"
4
let eventSourceInitDict = {headers: {'Accept': 'text/event-stream'}};
5

6
async function main() {
7
  let es = new EventSource(url, eventSourceInitDict);
8

9
  es.addEventListener('head', function (e) {
10
      console.log(e.data)
11
  })
12
}
13

14
main();

1
import json
2
import sseclient
3
import requests
4

5
url = "https://docs-demo.xdai.quiknode.pro/eth/v1/events?topics=head"
6

7
response = requests.get(url, stream=True, headers={'Accept': 'text/event-stream'})
8
client = sseclient.SSEClient(response)
9

10
for event in client.events():
11
    subscriptionData = json.loads(event.data)
12
    print(json.dumps(subscriptionData, indent=2))

1
import json
2
import sseclient
3
import requests
4

5
url = "https://docs-demo.xdai.quiknode.pro/eth/v1/events?topics=head"
6

7
response = requests.get(url, stream=True, headers={'Accept': 'text/event-stream'})
8
client = sseclient.SSEClient(response)
9

10
for event in client.events():
11
    subscriptionData = json.loads(event.data)
12
    print(json.dumps(subscriptionData, indent=2))

1
require "uri"
2
require "net/http"
3

4
url = URI("https://docs-demo.xdai.quiknode.pro/eth/v1/events?topics=head")
5

6
https = Net::HTTP.new(url.host, url.port)
7
https.use_ssl = true
8

9
request = Net::HTTP::Get.new(url)
10
request["accept"] = "text/event-stream"
11

12
https.request(request) do |response|
13
  if response.code == "200"
14
    response.read_body do |chunk|
15
      puts chunk
16
    end
17
  else
18
    puts "Error: #{response.code} - #{response.message}"
19
  end
20
end

1
require "uri"
2
require "net/http"
3

4
url = URI("https://docs-demo.xdai.quiknode.pro/eth/v1/events?topics=head")
5

6
https = Net::HTTP.new(url.host, url.port)
7
https.use_ssl = true
8

9
request = Net::HTTP::Get.new(url)
10
request["accept"] = "text/event-stream"
11

12
https.request(request) do |response|
13
  if response.code == "200"
14
    response.read_body do |chunk|
15
      puts chunk
16
    end
17
  else
18
    puts "Error: #{response.code} - #{response.message}"
19
  end
20
end

Don't have an account yet?

Create your Quicknode endpoint in seconds and start building

Get started for free