Viktor Klang
66a116d3d2
-str - Improvements and renames in internal streams classes
...
* Renames Module.grow -> Module.compose
* Renames Module.connect -> Module.wire
* Renames Module.growConnect -> Module.fuse
* Renames Module.wrap -> Module.nest
* Adds explicit identity equals and hashCode to InPort and OutPort
* Reimplements many of the Source factories to avoid copying
* Documents Module.compose, Module.fuse, Module.wire and Module.nest
* Removes Attributes.nameLifted
* Optimizes Attributes.nameOrDefault
2015-07-13 23:39:45 +02:00
Viktor Klang
2725bfc044
=str - Various internal Akka Stream improvements
...
* Gives Inlets and Outlets a `carbonCopy` method and switches to allocate them via `apply`
* Removes 4 Array allocations per FanIn and uses a bitmasked array instead
* Makes the FlattenStrategy.concat instance a singleton
2015-06-30 11:45:50 +02:00
Viktor Klang
36abbb4234
Introduces fold as a Flow transformation and generalizes Sink.fold to be Flow.fold + Sink.head
...
Conflicts:
akka-stream/src/main/scala/akka/stream/impl/ActorMaterializerImpl.scala
akka-stream/src/main/scala/akka/stream/impl/Stages.scala
akka-stream/src/main/scala/akka/stream/scaladsl/Sink.scala
2015-06-30 10:17:52 +02:00
Endre Sándor Varga
292eba2d73
=str: Materializer should report being shut down on sys termination
2015-06-25 12:54:29 +02:00
Endre Sándor Varga
df35562c0b
Make broadcast cancellation configurable
2015-06-24 14:44:07 +02:00
Endre Sándor Varga
c7a974dd1e
Rename RunnableFlow to RunnableGraph
2015-06-23 18:49:53 +02:00
Endre Sándor Varga
7879a5521b
Rename FlowMaterializer to Materializer
2015-06-23 18:47:28 +02:00
