准备在发电机转轮中重复使用的函数

Preparing a function to repeatedly use in a generator runner

本文关键字：函数 发电机      更新时间：2023-09-26

我使用的是nodejs telnet实现，每次从telnet客户端接收数据时，它都会使用事件来提供通知，可以订阅如下：

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

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

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

我试过使用Baconjs来实现这一点，但我认为没有办法阻止在流上等待单个值，至少我找不到这样的方法。

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

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

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);
});

我通过在Baconjs中使用"fromEvent"和使用"firstToPromise"来实现这一点。我收到了来自"fromBinding"的异常，所以我不知道上面是什么，但这大大减慢了我的进度。

以下是简化的工作代码。需要ES6（我使用了节点标志--harmony_generators和--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);
    }
);
相关文章：