logsUnsubscribe RPC Method

पैरामीटर

number

लोड हो रहा है...

रिटर्न

परिणाम

बूलियन

लोड हो रहा है...

अनुरोध

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

3
const rpcSubscriptions = createSolanaRpcSubscriptions('');
4

5
अतुल्यकालिक समारोह मुख्य ( ) {
6
    const publicKeyString = address('E645TckHQnDcavVv92Etc6xSWQaq8zzPtPRGBheviRAk');
7
    const abortController = new AbortController();
8

9
    const subscription = await rpcSubscriptions
10
        .logsNotifications({ mentions: [publicKeyString] })
11
        .subscribe({ abortSignal: abortController.signal });
12

13
    let logCount = 0;
14

15
    try {
16
        for await (const notification of subscription) {
17
            logCount += 1;
18
            console.log(`Log #${logCount}: `, notification);
19

20
            if (logCount > 3) {
21
                console.log("Log count exceeded 3, unsubscribing...");
22
                break;
23
            }
24
        }
25
    } catch (e) {
26
        console.error("Error in logs subscription:", e);
27
    } finally {
28
        abortController.abort();
29
        console.log('Aborted subscription handling.');
30
    }
31
}
32

33
main();
34

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

3
const rpcSubscriptions = createSolanaRpcSubscriptions('');
4

5
अतुल्यकालिक समारोह मुख्य ( ) {
6
    const publicKeyString = address('E645TckHQnDcavVv92Etc6xSWQaq8zzPtPRGBheviRAk');
7
    const abortController = new AbortController();
8

9
    const subscription = await rpcSubscriptions
10
        .logsNotifications({ mentions: [publicKeyString] })
11
        .subscribe({ abortSignal: abortController.signal });
12

13
    let logCount = 0;
14

15
    try {
16
        for await (const notification of subscription) {
17
            logCount += 1;
18
            console.log(`Log #${logCount}: `, notification);
19

20
            if (logCount > 3) {
21
                console.log("Log count exceeded 3, unsubscribing...");
22
                break;
23
            }
24
        }
25
    } catch (e) {
26
        console.error("Error in logs subscription:", e);
27
    } finally {
28
        abortController.abort();
29
        console.log('Aborted subscription handling.');
30
    }
31
}
32

33
main();
34

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.removeOnLogsListener(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.removeOnLogsListener(0);
7
})();
8

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

6
अतुल्यकालिक डीईएफ़ मुख्य ( ) :
7
    async with connect("") as websocket:
8
        await websocket.log_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.account_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
अतुल्यकालिक डीईएफ़ मुख्य ( ) :
7
    async with connect("") as websocket:
8
        await websocket.log_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.account_unsubscribe(subscription_id)
16

17
asyncio.run(main())

1
wscat -c  \ 
2
# कनेक्शन की प्रतीक्षा करें 
3
{"id":1,"jsonrpc":"2.0","method": "logsUnsubscribe", "params": [0]}
4

1
wscat -c  \ 
2
# कनेक्शन की प्रतीक्षा करें 
3
{"id":1,"jsonrpc":"2.0","method": "logsUnsubscribe", "params": [0]}
4

प्रतिक्रिया

1
{
2
  "jsonrpc" : "2.0" ,
3
  "result": true,
4
  "पहचान" : 1
5
}

1
{
2
  "jsonrpc" : "2.0" ,
3
  "result": true,
4
  "पहचान" : 1
5
}

अब तक कोई खाता नहीं है?

कुछ ही सेकंड में अपना क्विकनोड एंडपॉइंट बनाएं और निर्माण शुरू करें।

मुफ़्त में शुरुआत करें