Stream Uniswap v3 swaps for a specific pool, or for every WETH/USDG pool of a token. Backed by the gap-fill log cursor: a dropped RPC connection or blip re-reads the missed block range instead of silently losing swaps.
const swaps = await streamSwaps(hood, { token: '0x…' })swaps.on('data', (s) => console.log(s.buysToken0 ? 'BUY' : 'SELL', s.price)) Copy
const swaps = await streamSwaps(hood, { token: '0x…' })swaps.on('data', (s) => console.log(s.buysToken0 ? 'BUY' : 'SELL', s.price))
Stream Uniswap v3 swaps for a specific pool, or for every WETH/USDG pool of a token. Backed by the gap-fill log cursor: a dropped RPC connection or blip re-reads the missed block range instead of silently losing swaps.