Tag: frp

准备一个function，重复使用发电机运行

我正在使用一个nodejs telnet实现，它使用一个事件来提供通知，每次从远程login客户端接收数据时，可以按如下方式进行订阅： client.on('data', [callback]); 我也使用了一个生成器runner（npm上的generator-runner）来执行工作stream。 我遇到的问题是，以这种方式产生值需要更多的承诺：传递一个委托来处理单个值。 我将如何去编写一个可以放置在生成器yield函数中的函数，并且每当我想要产生更多的input时可以重复这个函数？ 我已经尝试过使用Baconjs，但是我不认为有阻止在stream上等待一个值的方法，至less我找不到这样的方法。 我愿意接受任何build议。 我唯一真正的要求就是能够将我的工作stream程放在一个平坦的代码块中，而不用链接承诺。 这里是我嘲笑的代码，这根本不起作用： var requirejs = require('requirejs'); requirejs(['telnet', 'baconjs', 'colourise', 'lodash', 'generator-runner'], function(Telnet, Bacon, Colourise, _, Async) { var configureClient = client => { client.do.transmit_binary(); }; Telnet.createServer(client => { var session = { connectedAt: Date.now(), user: { } }, write = _.compose(_.bind(client.write, client), Colourise.encode), readStream = Bacon.fromBinder(function […]