import { getNetworkEndpoints, Network } from '@injectivelabs/networks'
import {
StreamManagerV2,
IndexerGrpcAccountPortfolioStreamV2
} from '@injectivelabs/sdk-ts/client/indexer'
const endpoints = getNetworkEndpoints(Network.Testnet)
const stream = new IndexerGrpcAccountPortfolioStreamV2(endpoints.indexer)
const streamManager = new StreamManagerV2({
id: 'account-portfolio',
streamFactory: () => stream.streamAccountPortfolio({
accountAddress: 'inj...',
callback: (response) => {
streamManager.emit('data', response)
}
}),
onData: (portfolioResults) => {
console.log(portfolioResults)
},
retryConfig: { enabled: true }
})
streamManager.on('connect', () => console.log('Stream connected'))
streamManager.start()