Repository navigation
Socket.io change feed help (performance) #1230
Description
Hello, im setting up a change feed that pushes to a socket io connection.
Im worried that setting up a new change feed for each io connection is gonna be a bit intensive.
Can rethink handle 100-1000 change feeds OK ?
Ill post my code below and any advice or feedback would be amazing, this is my first time using change feeds.
Also so i need to 'unsubscribe' from the change feed ?
Here is my current code :
startSocket() {
this.io.sockets.on('connection', socket => {
console.log(' %s sockets connected', this.io.engine.clientsCount)
socket.on('new_connection', target => {
rethink
.table(target)
.changes({ includeInitial: true })
.run((err, cursor) => {
cursor.each((err, item) => {
socket.emit(target, item.new_val)
})
})
})
socket.on('disconnect', function() {
console.log('disconnect: ', socket.id)
})
})
}
Thanks
Luke
Activity
Samhamsam commentedon Mar 30, 2020
Same problem here. How did you solve it?
SamLebarbare commentedon Apr 21, 2020
Handle changes state in a store, mutate the store when a change occur,
new socket connection must get store state, sub to store changes.
redux pattern is ideal for that.