准备一个函数以在生成器运行器中重复使用

Posted 2023-03-16

【中文标题】准备一个函数以在生成器运行器中重复使用

【英文标题】：Preparing a function to repeatedly use in a generator runner

【发布时间】：2015-06-02 10:25:06

【问题描述】：

我正在使用 nodejs telnet 实现，每次从 telnet 客户端接收到数据时，它使用事件来提供通知，可以按如下方式订阅：

client.on('data', [callback]);

我还使用生成器运行器（npm 上的生成器运行器）来执行工作流。

我遇到的问题是，以这种方式产生值需要更像是一个承诺：传递单个委托来处理单个值。我将如何编写一个可以放置在生成器 yield 语句中的函数，并且每次我想产生更多输入时都可以重复？

我已经尝试过为此使用 Baconjs，但我认为没有办法阻止等待流上的单个值，至少我找不到这样的方法。

我愿意接受任何建议。我唯一真正的要求是我能够将我的工作流放在一个扁平的代码块中，而无需链接 Promise。

这是我模拟的代码，它根本不起作用：

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 (sink) 
            client.on('data', function (data) 
                sink( client : client, data : data, session : session );
            )),
        read = () => readStream.take(1).toPromise();

        configureClient(client);
        write("%xxWelcome!\r\n")

        Async(function*()
            write("Username: ");
            var user = yield read();
            console.write("Username entered: " + user);

            write("Password: ");
            var password = yield read();
            console.write("Password entered: " + password);
        );
    ).listen(8100);
);

【参考方案1】：

我已经通过在 Baconjs 中使用“fromEvent”和使用“firstToPromise”来完成这项工作。我收到了“fromBinding”引发的异常，所以我不知道那里发生了什么，但这大大减慢了我的进度。

以下是简化且有效的代码。需要 ES6（我使用了节点标志 --harmony 和 --harmony_generators。）

另一方面，我对这项技术的意义感到非常兴奋！

var requirejs = require('requirejs');
requirejs(['telnet', 'baconjs', 'generator-runner', 'lodash'],
    function(Telnet, Bacon, Async, _) 
        var configureClient = client => 
            client.do.transmit_binary();
        ;

        Telnet.createServer(client => 
            var write = _.bind(client.write, client),
                readStream = Bacon.fromEvent(client, 'data'),
                readAsync = () => readStream.firstToPromise();

            configureClient(client);
            write("Welcome!\r\n")

            Async(function*()
                write("Username: ");
                var user = yield readAsync();
                console.log("Username entered: " + user);

                write("Password: ");
                var password = yield readAsync();
                console.log("Password entered: " + password);
            );
        ).listen(8100);
    
);