这看起来不可思议,但我找不到akka流
源代码存储库。主github repo包含一个akka stream dir,但不包含当前的发布源。
目前,我设法通过-源代码访问代码。jar
发布:http://search.maven.org/remotecontent?filepath=com/typesafe/akka/akka-stream-experimental_2.11/2.0.1/akka-stream-experimental_2.11-2.0.1-sources。罐子
Akka Stream源代码存储库在哪里?
在@ktoso注释后编辑
@ktoso似乎在github
上更新了akka
存储库。现在出现了commit1d8f6f3
和相关标签akka-stream-and-http-experimental-2.0.1
。
似乎最近有提交(截至2015年12月30日)在该目录中的最新*-dev分支https://github.com/akka/akka/tree/release-2.3-dev/akka-stream/src
编辑:根据康拉德·科托索·马拉夫斯基的评论;https://github.com/akka/akka/tree/akka-stream-and-http-experimental-2.0.1
当接收到消息时,它将运行,并将接收到的每个项发布到。 我怎么能那么做? 以防万一它可能会添加更多选项,请注意,另一个代码块是的Websocket处理程序。
我想要一个以给定的时间间隔计算函数并发出其输出的源。作为一种变通方法,我可以通过,但还没有找到更干净的方法。理想情况下,我会有 有什么想法吗?
我的服务代码如下所示, 在我的AKKA HTTP路由中,我尝试从返回的未来构建,如下所示, 我不确定如何提交给响应。被传递的未来实质上是一系列预期按顺序执行的平面映射的未来。但是,我不相信这会作为分块字节流返回到客户端。 然而,我只得到最后一个未来的结果如下, 亲切地问候Meeraj
这可能吗?我所做的更改需要在服务器上被识别,以便更改不仅仅发生在我的计算机上。此外,我甚至不知道是否可以在不下载外部插件的情况下查看实际的源代码(由于某些原因,外部插件无法工作)。有人做过这样的事吗?
我试图构建一个Akka流源,它通过发出API调用来接收数据(API的本质是滚动,它增量地获取结果)。为了构建这样的源码,我使用了GraphStage。 我修改了NumberSource示例,它只是一次推送一个。我所做的唯一更改是将替换为(以模拟API调用): 上面的代码不起作用。中的println语句只执行一次,不向下游推送任何内容。 这类未来来电应如何处理?谢了。
问题内容: 是否可以从源代码修改或创建配置文件。我正在使用远程创建一些客户端/服务器体系结构。我要实现的功能是使用以下命令启动客户端应用程序:主机/端口,并且在尚无配置文件时创建一个可满足命令行args的功能。 配置并不复杂。我想从源端口更改(最终是主机,现在无论如何都为主机测试)以使其自动化,这样我就可以通过将多个客户端传递给主函数来运行多个客户端。 问题答案: 是的,您可以在代码中修改或创建配