13 replies

tRPC + WebSocket Client

I have a WebSocket between my backend and an external server. I'm trying to get to this:

WebSocket Server → Next.js backend → users

WebSocket Server → Next.js backend → users

I have gone through tRPC's documentation on subscriptions (https://trpc.io/docs/subscriptions) and a few examples, but none seemed to work the way I need it.

I currently have it as a

query

query

using WebSocket messages cached in a

Map

Map

const cache = Map<number, Status>()
socket.onmessage = ({data}) => data.forEach(d => cache.set(d.id, d))

// then
const { data } = useQuery(undefined, { refetchInterval: 5_000 })

const cache = Map<number, Status>()
socket.onmessage = ({data}) => data.forEach(d => cache.set(d.id, d))

// then
const { data } = useQuery(undefined, { refetchInterval: 5_000 })

Subscriptions / WebSockets | tRPC

Using Subscriptions

TTC

Theo's Typesafe Cult•4y ago•

13 replies

Mocha

tRPC + WebSocket Client

I have a WebSocket between my backend and an external server. I'm trying to get to this:

WebSocket Server → Next.js backend → users

WebSocket Server → Next.js backend → users

I have gone through tRPC's documentation on subscriptions (https://trpc.io/docs/subscriptions) and a few examples, but none seemed to work the way I need it.

I currently have it as a

query

query

using WebSocket messages cached in a

Map

Map

const cache = Map<number, Status>()
socket.onmessage = ({data}) => data.forEach(d => cache.set(d.id, d))

// then
const { data } = useQuery(undefined, { refetchInterval: 5_000 })

const cache = Map<number, Status>()
socket.onmessage = ({data}) => data.forEach(d => cache.set(d.id, d))

// then
const { data } = useQuery(undefined, { refetchInterval: 5_000 })

Subscriptions / WebSockets | tRPC

Using Subscriptions

tRPC + WebSocket Client

Similar Threads

tRPC + WebSocket Client

Similar Threads

Similar Threads

Similar Threads