问题标签 [node-fibers]

最近几天（！）尝试了各种 Meteor/OpenShift 配置。简而言之，有点混乱，但最常见的问题是流星捆绑需要 Fibers 模块作为可下载的 repo 给出，如下所示

但似乎无法访问。

重点来了，我不知道如何在 OpenShift 上运行流星应用程序，但必须经过多次手动（使用 ssh 控制台）Fibers 安装/卸载

还有一个……链接 https://github.com/meteor/node-fibers/tarball/d519f0c5971c33d99c902dad346b817e84bab001似乎是有效的。

那么有什么问题

??

我想上传 csv 文件并在经过大量验证和一些过程后将其插入数据库。我正在使用fibers异步调用。但是即使光纤返回，光纤进程也会继续执行future.wait();。

saveCalender函数每次执行。我是否错过了停止纤程执行或如何停止纤程执行的任何内容？

我需要运行两个嵌套的异步函数并将第二个函数的回调返回给客户端。future.return 在 Fibers 中不起作用。如何在不使用集合的情况下将结果返回给客户端？

我试图了解如何在 fast-csv 中使用 Fiber 来制作逐行阅读器（单用户命令行脚本），该阅读器在每一行暂停读取/处理，直到该行完成各种异步调用. （不滚动我自己的 csv 代码，我想使用一些已经弄清楚关于 csv 格式的问题的东西）

如果我这样做

我得到了我的期望：

如果我尝试在每条记录后使用 Fiber

我明白了

我想我明白发生了什么，Fiber().run() 中的代码完成了，所以它在调用 yield 之前离开了 Fiber，所以当它达到 yield 时不再有 Fiber。（因此聪明的错误消息“没有光纤运行”）

在我完成解析之前，让我保持光纤运行的合适方法是什么？

似乎是一个简单的问题，但我没有看到明显的答案？起初，我想在它离开 Future().run() 之前设置一个 yield，但这不起作用，因为第一个 fiber.run() 会让它再次离开 Fiber。

我想要的是流程是这样的：

但如果不重新处理 fast-csv 的内部，这可能是不可能的，因为它控制了每个记录何时触发事件。我目前的想法是，必须让每个事件在 fast-csv 中被触发，并让处理 csv.on("record") 中的事件的用户将控制权交还给快速解析 csv 的循环-csv。

下面的代码行是做什么的？

我在网上找了一些例子，我遇到了一些这样的例子：

在这种情况下会有什么accessToken变量？

我正在尝试使用 Meteor 方法从一个 API 获取 json 数据，我尝试使用流星 wrapAsync 以及 Node Future。下面是我的代码：

模板助手 - 客户端

方法一：使用 Meteor wrapAsync - 服务器端

方法二：使用Node Fiber Future-Server端

在这两种方法中，我都在控制台中打印了值，但没有返回它们。

下面是截图：

我不知道我错在哪里，有人可以给我一些建议。

编辑：添加模板代码：

我想停止（优雅地或不优雅地）通过光纤运行的功能。Fibers 有 throwInto() 和 reset() 方法来做到这一点。但是当我使用它时，我的回调重新启动。你知道为什么吗 ？

这是我所做的一个小例子。

代码：

输出 ：

我有一些无限循环的 JS 代码（我们使用节点纤维来允许事情发生）。

ESLint 讨厌：

因为恒定的条件。

但以下是允许的：

除了喂 lintbeast 之外，还有什么客观的理由支持for（while反之亦然）吗？

注意：这个问题明确要求客观原因，因此不仅仅是基于意见。

我正在运行 Meteor 1.3.2.4 和 Node v4.4.3 。我所有的项目都不再加载并显示以下错误。起初这是Cannot find modules fibers我做的一个错误，并且meteor build --directory ../build我在这里看到了cd .meteor/local/build/programs/servernpm install 。 然后错误变为：

我也尝试在服务器文件夹中卸载和重新安装光纤，但无济于事。

流星似乎在我的笔记本电脑上运行良好，运行相同的版本，而不是我的台式机。

我有一堆代码需要同步运行。为了实现这一点，我正在使用fibers/future库。代码工作正常，但我不确定它是否是从fibers/future.

代码

• 功能

  /li>

var create_customer = Future.wrap(function(api_object, name, callback){

• API

router.route('/create_customer').post(function(req, res){

在这里，您可以看到我正在使用fibers/future使我的异步调用以同步方式工作。我.wait()用来等待命令完成并绑定未来的任务和功能。这种方法正确吗？