文件名称:future-streams:基于Scala基于Future的React流实现
文件大小:121KB
文件格式:ZIP
更新时间:2024-06-12 07:35:22
Scala
未来流 基于scala.concurrent.Future的带反压的流模型,并支持 。 同步流操作是同步执行的,而不是将每个步骤放在单独安排的Future 。 目的和设计约束 该库在scala中实现具有反压的异步流。 这是一个穷人的闲话流,其设计和目的与闲话流类似,但规模要小得多。 这使我能够快速编写,测试和交付它,因为我已经等不及akka流准备投产了。 Akka流应该在接下来的几个月中准备就绪,然后这个库就会过时了。 我希望将来自己改用akka-streams。 因此,未来的流不包括一些好的功能和设计选择,因为它们将花费太多的工作来实施和测试。 future-streams可以支持往返于Reactive Streams的转换器并通过RS 1.0-RC1 TCK,但我尚未编写该代码。 高层描述 注意:主要类型(例如Source和Sink的Scaladoc是行为详细信息的权威参考。 这只
【文件预览】:
future-streams-master
----gradlew.bat(2KB)
----gradlew(5KB)
----TODOs.md(3KB)
----LICENSE(11KB)
----gradle()
--------wrapper()
----src()
--------test()
--------main()
----.gitignore(86B)
----README.md(22KB)
----settings.gradle(38B)
----build.gradle(3KB)