reactive-streams

    4热度

    1回答

    端到端反应流式RESTful服务（又名背压HTTP）

    我一直试图在网上澄清这个问题一段时间没有成功，所以我会试着在这里问一下。 我想找到一些资源或示例，说明如何构建端到端完全反压REST服务+客户端。我的意思是，我希望看到，给定一个实现响应流的REST客户端（无论是Akka，JS还是其他），我将（并且能够“可视化”）整个过程中处理的背压建立REST服务器，例如与Akka-Http。 要清楚，我正在寻找类似下面的通话（但我找不到幻灯片或视频进行确认）：
    scala rest akka akka-stream reactive-streams 2015-05-18

    2热度

    1回答

    测试阿卡反应流

    我测试代码哪些流通过获得一个多输出流的TCP连接的消息： (IO(StreamTcp) ? StreamTcp.Connect(settings, address)) .mapTo[StreamTcp.OutgoingTcpConnection] .map(_.outputStream) 在测试中，我与虚拟用户替换所得Subscriber[ByteString]，引发一些传出消息，并声称已
    scala akka akka-stream reactive-streams 2014-09-24

    8热度

    2回答

    如何使用Reactive Streams进行NIO二进制处理？

    是否有一些代码示例使用org.reactivestreams库来处理使用Java NIO（用于高性能）的大型数据流？我瞄准分布式处理，所以使用Akka的例子是最好的，但我可以弄清楚。 它似乎仍然是这种情况，大多数（我希望不是全部）的读取阶度假村文件Source（非二进制）或直接的Java NIO的例子（甚至之类的东西Files.readAllBytes！） 也许我错过了一个激活模板？ （Akka
    scala akka nio reactive-streams 2015-01-05

    1热度

    1回答

    撰写流程图

    我一直在玩Akka Streams，并得到创建Flow s并使用FlowGraph s将它们连接在一起的想法。 我知道Akka的这部分还在开发中，所以有些东西可能无法完成，其他一些位可能会改变，但是可以创建一个不完整的FlowGraph - 即不附加到一个Sink - 并将其传递给我的代码的不同部分，通过添加Flow来扩展它，最后通过添加一个Sink来完成？ 基本上，我希望能够编写FlowGrap
    akka reactive-streams 2014-12-06
最新问题