Gestion des stream Nodejs avec AngularJS Node.js Girl

J’utilise les stream nodejs pour récupérer les données de ma firebase database level (en utilisant leveldb). Voici un extrait du code que j’utilise:

app.get('/my/route', function (req, res, next) { leveldb.createValueStream(options) .pipe(map.obj(function (hash) { level.get(somekeys, function (err, item) { return item }) })) .pipe(res) })

Jusqu’à présent, j’utilisais le module list-stream pour obtenir les données côté client.

Maintenant, j’aimerais récupérer les informations côté client sous forme de stream. J’ai lu ce post ( http://www.kdelemme.com/2014/04/24/use-socket-io-to-stream-tweets-between-nodejs-and-angularjs/ ) sur la façon de le faire en utilisant socket.io mais je ne veux pas utiliser socket.io

Y a-t-il un moyen simple de le faire?

Cela peut être fait avec Shoe . Vous devez comstackr le code client avec browserify et vous pouvez avoir un stream dans le navigateur qui reçoit les données du serveur.

La createValueStream est fondamentalement un stream de lecture. Vous pouvez ensuite écouter l’événement, par exemple, les data , la end : https://github.com/substack/node-levelup#createValueStream

Juste besoin d’écouter pour end événement pour terminer le stream.

  app.get('/my/route', function (req, res, next) { leveldb.createValueStream(options) .pipe(map.obj(function (hash) { level.get(somekeys, function (err, item) { return item }) })) .pipe(res) .on('end', res.end) })