Skip to main content
For the raw wire protocol, see the Streaming API v2 specification.
TransportDescription
ToncenterSSEOne-way stream. Single POST request, server pushes events.
ToncenterWebSocketBidirectional. Dynamic subscribe/unsubscribe after connect.

​
Endpoints

NetworkURL
Mainnethttps://toncenter.com/api/streaming/v2/sse
Testnethttps://testnet.toncenter.com/api/streaming/v2/sse

​
SDK Usage

import asyncio

from toncenter.types import Network
from toncenter.streaming import Finality, ToncenterSSE, TransactionsNotification

sse = ToncenterSSE("YOUR_API_KEY", Network.MAINNET)


@sse.on_transactions(min_finality=Finality.FINALIZED)
async def on_tx(n: TransactionsNotification) -> None:
    for tx in n.transactions:
        print(tx.get("hash"))


async def main() -> None:
    try:
        await sse.start(addresses=["EQDtFpEwcFAEcRe5mLVh2N6C0x-_hJEM7W61_JLnSF74p4q2"])
    finally:
        await sse.stop()


if __name__ == "__main__":
    asyncio.run(main())
PageContent
ClientConstructor parameters, start, stop.
HandlersDecorator API and event registration.
EventsFinality, notification models, action types.
ConnectionState, reconnect policy, dynamic subscription.
See Reference for retry policy and session management.

​
Errors

Streaming-specific exceptions: ToncenterStreamingError and ToncenterConnectionLostError. See Connection for details and Reference for the full exception hierarchy.