Бесконечный поток с Baconjs

Question

У меня есть простой скрипт, который просто принимает все значения из списка Redis и печатает их на консоли.

var redis = require("redis"), 
    client = redis.createClient(); 
    Bacon = require('baconjs'); 

Bacon.repeat(function(){ 
    return Bacon.fromNodeCallback(
    client, 'lpop', ['errors'] 
); 
}) 
.takeWhile(function(val) {return val !== null;}) 
.fold(
    [], 
    function(acc, next) { 
     acc.push(next); return acc; 
    } 
).onValue(console.log); 

Программа печатает правильный список, но не заканчивается. Как я могу исправить проблему? И почему это происходит?

Answer 1

Простым решением является вызов process.exit внутри вашего обработчика onValue.

).onValue(function(value) { 
    console.log(value) 
    process.exit(0) 
}) 

РЕДАКТИРОВАТЬ: Вы можете написать пользовательский источник, который закрывает соединение, когда он больше не нужен.

Bacon.fromBinder(function(sink) { 
    var client = redis.createClient() 
    sink(new Bacon.Next(client)) 
    return function unsubscribe() { 
    client.quit() 
    } 
}).flatMap(function(client) { 
    return Bacon.repeat(function(){ 
    return Bacon.fromNodeCallback(
     client, 'lpop', ['errors'] 
    ); 
    }) 
})