问题标签 [event-stream]

我正在努力让两条并行处理路线在 gulp 中工作。我的代码如下所示：

我在这里找到了一个建议，即这种分叉然后合并流的方式应该可行。但是，我收到错误：

问题似乎在于 es.merge 的使用，因为没有它（一个处理路径），一切都按预期工作。不幸的是，我对 node.js 流没有广泛的了解，所以我无法确定这个问题的原因。我的 Node 版本是 0.10.28，gulp 3.6.2 和 event-stream 是 3.1.5

我正在开发一个小应用程序。发送任务后，用户可以接收到一系列状态消息——通过这种方式，人们可以了解性能是否成功。这可以通过 SSE 和 JS 事件订阅来实现。问题是事件分布和变量隔离——我从未使用过多租户。

每个用户都应该使用自己的应用程序实例。每个用户都应该收到自己的事件。

我知道如何实现身份验证机制以及如何为每个任务提供唯一 ID，但是如何在 Sinatra 应用程序中实现多租户？有许多宝石和食谱，但它们都是为 RoR 编写的。

我的应用程序提供 Asterisk 传真处理。它由两部分组成：第一个是 Sinatra 的路由处理程序，第二个是后端进程 - 它侦听 Asterisk 事件（AMI），还提供新的任务发送。

正如人们所说，仍然很难理解我的应用程序应该做什么，我将逐步描述它。

1. 用户登录。
2. 用户发送电话任务（例如传真）。它必须是异步过程，因为你永远不知道会发生什么：可能会很忙，可能会在第 5 秒、第 9 秒出现答案……等等。
3. 因此，在此过程中，用户会收到描述正在发生的事情的消息（我们的后台进程与电话服务器通信）。
4. 然而此时另一个用户用户正在登录并发送他自己的任务。两个用户都可以看到他们的私人事件流。

但这不会发生：用户看到 2 个事件流的混乱。那是我的问题。

实际上，我的任务与聊天室实现类似，不同之处在于人们不应该互相交谈。他们应该通过服务器与后台进程“交谈”。每个人都可以说“你好”，服务器将“你好”重定向到后台进程，然后从后台进程返回一个私有的答案流给所有者，这是异步发生的。在聊天室中，你可以对另一个好友说“你好”，你永远不知道你什么时候会收到答案，但服务器知道这个答案是你的——你会得到你的私人答案。

以下是片段：

提前致谢。

我对 Android 开发和 Google App 引擎的东西很陌生。我仍在处理有关它的文档和教程。

我有一个 Android 游戏概念，基于 2 名玩家的回合制战斗，但回合非常短（< 20 秒）。据我所知，Google Cloud Endpoints 允许创建类似 REST 的 API。

应用程序有没有办法警告客户其他玩家已经玩过，并做出相应的反应？由于“小”计时器，预计不会在战斗期间离开应用程序。

到目前为止，我已经找到了 Channel API，但它不适用于 Android 客户端。

先感谢您 ！

我正在尝试通过 EventSource / Server-Sent Events 协议在 Windows Phone 上使用 Firebase API。

当我不设置Accept: text/event-stream. 通过这种方式，我得到了整个请求的 json。但是当Accept设置为text/event-stream时，任务不会继续。

request.AllowReadStreamBuffering设置为它false不会改变

谢谢！

我试图在 NodeJs 中使用EventSource时获取有关错误的信息，我认为您可以通过以下示例更好地理解我：

在onerror函数中，我想获取有关错误的信息，但它event是空的或未定义的以及es对象（嗯，这个对象只是带有一对花括号{}）。如果出现错误，我想读取响应标头，例如：

这可能吗？我错过了什么？我认为答案应该很简单，但我是 NodeJs 的新手。

我正在尝试将 css 和 scss 文件合并到我的构建目录中的 main.css 文件中。它的工作，但不是在正确的顺序。scss 文件中的样式属性需要位于 main.css 文件的底部，以便它们覆盖其余部分。

我的 Gulp 任务如下所示：

我首先用变量定义源。我正在使用 gulp-sass 插件将 scss 文件转换为普通 css (.pipe(sass))，然后使用 es.merge 函数将两者合并并将它们连接到 main.css。

问题是 .scss 文件的样式属性最终位于 main.css 文件的顶端。我需要他们在底部。所以它们需要在底部连接起来。

关于如何做到这一点的任何线索？

我使用event-stream它是为了在一项任务中编译 SASS 并将其与 CSS 合并。它工作得很好，我唯一的问题是sourcemap正在合并到 CSS 中。

吞咽代码

来源：main.SCSS

来源：main2.css

输出：style.min.css

我尝试过的事情

1)尝试：将 ruby​​Sass 的 sourcemap 设置为 false结果：没有区别

2. 试过： gulp-concat-sourcemap，这会创建我的外部源映射文件，但我的内部也有它style.min.css

   return es.concatSourceMap(gulp.src(cssGlob), sassFiles) .pipe(plugins.concat('style.min.css')) .pipe(gulp.dest(paths.styles.dest));

当我检查结果源图的输出时，我注意到了这一点

基于此，它似乎将 .map 文件连接到 CSS，这是我们看到的行为。所以我试图过滤掉它。

3）尝试：用于gulp-filter过滤掉地图文件以防止在css中连接结果：没有区别

"))

我有一个创建可读流的代码。我想在 getStream 方法中设置流的名称。我尝试设置一个属性，如下所示。我可以访问 onceFunction 中的属性，但无法访问 map Function 中的属性。让我知道我做错了什么

我有一个 node.js 程序，它使用流来读取文件（nodejs 事件流为每个流设置一个变量）

我想使用相同的程序将此数据写入弹性搜索。我写了一个小写函数

并将其与流媒体联系起来

以上按预期异步工作并写入数据，除了它需要很长时间。它似乎也可以作为缓冲区工作，因为写入需要比读取更长的时间。（使用管道的优势）我知道有一个弹性搜索中的批量接口，我可以使用它导入。Kibana 入门指南 ( http://www.elasticsearch.org/guide/en/kibana/current/using-kibana-for-the-first-time.html )中的shakesphere.json 示例

这意味着我需要以批量导入所需的格式创建文件，然后运行 ​​curl 程序等。我想避免创建临时文件。

作为流式传输过程的一部分，是否有更简单的方法可以更快地将数据导入弹性搜索

我有一个 php 脚本，可以从带有验证的 csv 文件中导入大数据。
为此，我需要向用户显示进度。我为此使用了事件流。
当我回显某些内容时，我希望将其一一传输到客户端，而不是服务器批量发送整个输出。
我已经玩过 ob_start()、ob_implicit_flush() 和 ob_flush()，但它们没有用。
我的脚本在另一台服务器上运行良好。下面给出服务器配置：

代码未按预期响应的服务器配置，即

正如我所说，代码在另一台具有几乎相同配置的服务器上正常工作，即

下面是我发送事件的示例代码：

以下是我需要回复的客户页面：