accountUnsubscribe RPC Method

Parameters

number

Loading...

Returns

result

boolean

Loading...

Request

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

3
async function handleAccountNotifications() {
4
    const rpcSubscriptions = createSolanaRpcSubscriptions('');
5
    const abortController = new AbortController();
6

7
    try {
8

9
        const accountNotifications = await rpcSubscriptions
10
            .accountNotifications(address('AxZfZWeqztBCL37Mkjkd4b8Hf6J13WCcfozrBY6vZzv3'), { commitment: 'confirmed' })
11
            .subscribe({ abortSignal: abortController.signal });
12

13
        let previousOwner = null;
14

15
        // Consume messages
16
        for await (const notification of accountNotifications) {
17
            const {
18
                value: { owner },
19
            } = notification;
20

21
            // Check if owner has changed
22
            if (previousOwner && owner !== previousOwner) {
23
                console.log('Owner has changed, aborting subscription.');
24
                abortController.abort();
25
                break;
26
            } else {
27
                console.log('Notification:', notification);
28
            }
29

30
            previousOwner = owner;
31
        }
32
    } catch (e) {
33
        console.error('Error while handling notifications:', e);
34
    } finally {
35
        console.log('Unsubscribed from account notifications');
36
    }
37
}
38

39
handleAccountNotifications();

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

3
async function handleAccountNotifications() {
4
    const rpcSubscriptions = createSolanaRpcSubscriptions('');
5
    const abortController = new AbortController();
6

7
    try {
8

9
        const accountNotifications = await rpcSubscriptions
10
            .accountNotifications(address('AxZfZWeqztBCL37Mkjkd4b8Hf6J13WCcfozrBY6vZzv3'), { commitment: 'confirmed' })
11
            .subscribe({ abortSignal: abortController.signal });
12

13
        let previousOwner = null;
14

15
        // Consume messages
16
        for await (const notification of accountNotifications) {
17
            const {
18
                value: { owner },
19
            } = notification;
20

21
            // Check if owner has changed
22
            if (previousOwner && owner !== previousOwner) {
23
                console.log('Owner has changed, aborting subscription.');
24
                abortController.abort();
25
                break;
26
            } else {
27
                console.log('Notification:', notification);
28
            }
29

30
            previousOwner = owner;
31
        }
32
    } catch (e) {
33
        console.error('Error while handling notifications:', e);
34
    } finally {
35
        console.log('Unsubscribed from account notifications');
36
    }
37
}
38

39
handleAccountNotifications();

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

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

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

18
asyncio.run(main())

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

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

18
asyncio.run(main())

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

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

Response

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

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

Don't have an account yet?

Create your Quicknode endpoint in seconds and start building

Get started for free