Konrad 'ktoso' Malawski
5b1c05f3fe
!str #15271 make transform() take a factory instead of Transformer
...
+ Makes reusing flows safe
+ Adds timerTransform for ops which need TimerTransformer
+ Adds TransformerLike in order to keep transform/timerTransform
typesafe in respect to the passed in type og Transformer
Resolves #15271
2014-08-22 14:21:02 +02:00
Alexey Romanchuk
edf59b1cd4
+str #15558 Initial delay support for TickProducer
2014-08-21 12:35:46 +07:00
Patrik Nordwall
fdc5532483
!str #15076 Make foreach a terminal operation, returning Future[Unit]
2014-08-15 17:32:46 +02:00
Viktor Klang
bb8ab0a925
= str - #15621 - Moving FlowMaterializer argument to the end of all Flow and Duct methods which uses it.
2014-08-05 11:36:07 +02:00
Endre Sándor Varga
d6fbadc61e
!str: #15474 : Migrate to reactive-streams 0.4.0.M1
2014-07-28 11:35:20 +02:00
Patrik Nordwall
e1bd39bf7d
+str #15218 Add mapFuture operator
2014-05-30 14:00:41 +02:00
Patrik Nordwall
1a96c23070
+str #15091 Add time driven operators
...
* TimerTransformer with support for named timers
* dropWithin
* takeWithin
* groupedWithin
2014-05-30 12:06:52 +02:00
Patrik Nordwall
2493a3fc91
+str #15080 Add tick producer
2014-05-30 10:06:07 +02:00
Patrik Nordwall
db5b27c17e
str =15252 Add dsl consistency spec
2014-05-27 13:50:16 +02:00
Endre Sándor Varga
50ab214d25
+str #15081 : Implement conflate, expand and buffer
2014-05-23 12:07:25 +02:00
Björn Antonsson
6cd2f7d5d8
Merge pull request #15268 from akka/wip-upgrade-stream-dependencies-to-akka-2.3.3-ban
...
=pro Upgrade akka-stream dependencies to akka 2.3.3
2014-05-23 09:53:20 +02:00
Endre Sándor Varga
a99902077e
+str #15088 , #15200 : Add takeAndTail and concatAll
2014-05-22 15:19:18 +02:00
Björn Antonsson
4f55b0d2e1
=pro Upgrade akka-stream dependencies to akka 2.3.3
...
* Upgrade dependency to akka 2.3.3
* Remove javadsl.Pair and javadsl.Predicate in favor of akka.japi.*
2014-05-22 14:39:57 +02:00
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
781acb0a4b
+str #15172 Add javadsl.Duct as free-standing Flow
...
* foreach Void
2014-05-15 16:29:45 +02:00
Patrik Nordwall
e9a2585050
+str #15174 Add dispatcher setting to FlowMaterializer
...
* Verify dispatcher with custom default mailbox
2014-05-14 22:04:44 +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
