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 |
|
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 |
|
Patrik Nordwall
|
f7f0fc437a
|
+str #15197 Add flow.append(duct)
* and duct.append(duct), and missing javadsl flow.produceTo
|
2014-05-21 17:22:49 +02:00 |
|
drewhk
|
46c299f838
|
Merge pull request #15194 from drewhk/wip-stream-cleanups-drewhk
+str Various cleanups of internal streams architecture
Fixes #15158
|
2014-05-19 16:53:38 +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 |
|
Jisoo Park
|
0606a5566f
|
=str #15221 Fix typo in scaladoc
|
2014-05-19 21:22:47 +09: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
|
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 |
|