slotUnsubscribe RPC Method

Parameter

Zahl

Wird geladen...

Rücksendungen

Ergebnis

Wird geladen...

Anfrage

1
import { createSolanaRpcSubscriptions } from '@solana/kit';
2

3
const rpcSubscriptions = createSolanaRpcSubscriptions('');
4

5
async Funktion main() {
6
    const abortController = new AbortController();
7
    
8
    const subscription = await rpcSubscriptions
9
        .slotNotifications()
10
        .subscribe({ abortSignal: abortController.signal });
11

12
    let count = 0;
13
    const maxNotifications = 5;
14

15
    versuchen {
16
        for await (const notification of subscription) {
17
            console.log("Updated slot info: ", notification);
18
            count++;
19

20
            if (count >= maxNotifications) {
21
                console.log(`Received ${maxNotifications} notifications. Unsubscribing...`);
22
                break;
23
            }
24
        }
25
    } catch (e) {
26
        console.error(e);
27
    } finally {
28
        abortController.abort();
29
        console.log('Unsubscribed from slot changes');
30
    }
31
}
32

33
function unsubscribeAfterDelay(abortController: AbortController, delayMs: number) {
34
    setTimeout(() => {
35
        abortController.abort();
36
        console.log('Manually unsubscribed from slot changes after delay');
37
    }, delayMs);
38
}
39

40
Hauptseite();

1
import { createSolanaRpcSubscriptions } from '@solana/kit';
2

3
const rpcSubscriptions = createSolanaRpcSubscriptions('');
4

5
async Funktion main() {
6
    const abortController = new AbortController();
7
    
8
    const subscription = await rpcSubscriptions
9
        .slotNotifications()
10
        .subscribe({ abortSignal: abortController.signal });
11

12
    let count = 0;
13
    const maxNotifications = 5;
14

15
    versuchen {
16
        for await (const notification of subscription) {
17
            console.log("Updated slot info: ", notification);
18
            count++;
19

20
            if (count >= maxNotifications) {
21
                console.log(`Received ${maxNotifications} notifications. Unsubscribing...`);
22
                break;
23
            }
24
        }
25
    } catch (e) {
26
        console.error(e);
27
    } finally {
28
        abortController.abort();
29
        console.log('Unsubscribed from slot changes');
30
    }
31
}
32

33
function unsubscribeAfterDelay(abortController: AbortController, delayMs: number) {
34
    setTimeout(() => {
35
        abortController.abort();
36
        console.log('Manually unsubscribed from slot changes after delay');
37
    }, delayMs);
38
}
39

40
Hauptseite();

1
const web3 = require("@solana/web3.js");
2
(async () => {
3
  const solanaConnection = new web3.Connection("https://docs-demo.solana-mainnet.quiknode.pro/", {
4
    wsEndpoint: "",
5
  });
6
  solanaConnection.removeSlotChangeListener(0);
7
})();
8

1
const web3 = require("@solana/web3.js");
2
(async () => {
3
  const solanaConnection = new web3.Connection("https://docs-demo.solana-mainnet.quiknode.pro/", {
4
    wsEndpoint: "",
5
  });
6
  solanaConnection.removeSlotChangeListener(0);
7
})();
8

1
import solana
2
import asyncio
3
from asyncstdlib import enumerate
4
from solana.rpc.websocket_api import connect
5

6
async def main():
7
    async with connect("") as websocket:
8
        await websocket.slot_subscribe()
9
        first_resp = await websocket.recv()
10
        subscription_id = first_resp.result
11
        async for idx, msg in enumerate(websocket):
12
            if idx == 3:
13
                break
14
            print(msg)
15
        await websocket.slot_unsubscribe(subscription_id)
16

17
asyncio.run(main())

1
import solana
2
import asyncio
3
from asyncstdlib import enumerate
4
from solana.rpc.websocket_api import connect
5

6
async def main():
7
    async with connect("") as websocket:
8
        await websocket.slot_subscribe()
9
        first_resp = await websocket.recv()
10
        subscription_id = first_resp.result
11
        async for idx, msg in enumerate(websocket):
12
            if idx == 3:
13
                break
14
            print(msg)
15
        await websocket.slot_unsubscribe(subscription_id)
16

17
asyncio.run(main())

1
wscat -c  \ 
2
# wait for connection 
3
{"id":1,"jsonrpc":"2.0","method": "slotUnsubscribe", "params": [0]}
4

1
wscat -c  \ 
2
# wait for connection 
3
{"id":1,"jsonrpc":"2.0","method": "slotUnsubscribe", "params": [0]}
4

Antwort

1
{
2
  „jsonrpc“: "2.0",
3
  "result": true,
4
  „id“: 1
5
}

1
{
2
  „jsonrpc“: "2.0",
3
  "result": true,
4
  „id“: 1
5
}

Haben Sie noch kein Konto?

Erstellen Sie Ihren Quicknode-Endpunkt in Sekundenschnelle und legen Sie los

Kostenlos loslegen