Here you can publish from a search page one at a time.

basic-server.js

'use strict';

import knex from 'knex';
import express from 'express';
import socket from 'socket.io';
import bodyParser from 'body-parser';

export const app = express();
export const db = knex({ client: 'pg', /** your config here */ });
app.use((req, res, next) => {
  req.db = db;
  next();
});

export const server = http.createServer(app).listen(8124);
export const io = socket.listen(server);

// some boilerplate code here

// now you can use a route like this
app.route('/products', async function (req, res, next) {
  const search = req.db('products').select('*').where(req.queryParams).stream();
  search.on('data', d => io.emit('result', d));
  search.on('end', res.end.bind(res));
});