Commit graph

11 commits

Author SHA1 Message Date
Endre Sándor Varga
646b376333 +str : Various cleanups of internal streams architecture
- factor out receive blocks for inputs and outputs
 - pump uses TransferPhases and become
 - Unification of Transformer and RecoveryTransformer
2014-05-19 14:26:41 +02:00
Patrik Nordwall
aedc57eb66 +str #15034 Add Flow javadsl
* move Transformer to akka.stream package
* and Java API for StreamIO
2014-05-12 20:41:17 +02:00
Patrik Nordwall
f5ac4bb4b1 +str #15108 Use value equality on Producers wrapping iterables
* Fixes #15108
2014-05-12 17:17:06 +02:00
Patrik Nordwall
b548395e2f +str #15093 Add flow logging facility
* Fixes #15093
* Add Transformer.onError
2014-05-12 17:04:44 +02:00
Patrik Nordwall
3bb9471072 +str #15084 Use sensible flow processor actor names 2014-05-12 16:53:47 +02:00
Patrik Nordwall
aced77cccb +str #15085 Add Duct as free-standing Flow 2014-05-12 11:45:20 +02:00
Patrik Nordwall
90e4ca04d2 Merge pull request #15141 from akka/wip-15105-tee2-patriknw
+str #15105 Add Flow tee
2014-05-12 11:10:10 +02:00
Patrik Nordwall
76647b34bc +str #15071 Add Flow.apply from a Future 2014-05-08 09:46:02 +02:00
Patrik Nordwall
ab9b6ea023 +str #15105 Add Flow tee 2014-05-07 14:21:15 +02:00
Patrik Nordwall
d998d0184f !str #15063 Add Flow.Transformer interface
* Skip wrapping RecoveryTransformer elements in Try
* this will make it possible to use the same RecoveryTransformer interface
  for javadsl and scaladsl, which is important if we package building
  blocks in Transformer classes
* also avoids wrapper allocation
2014-05-07 11:07:45 +02:00
Patrik Nordwall
a318676f4a !str Rename ProcessGenerator to FlowMaterializer 2014-04-16 17:12:21 +02:00
Renamed from akka-stream/src/main/scala/akka/stream/impl/ProcessorGenerator.scala (Browse further)