raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10
1100 commits 1 branch 31 tags 268 MiB
Commit graph

54 commits

Author SHA1 Message Date
Konrad Malawski
05ad8a1479 Merge pull request #16212 from akka/wip-conflate-type-inference-√ 
+str - improves type inference on  by separating the seed from the op (c...
 2014-11-04 09:56:42 +01:00
Viktor Klang
82095da708 +str - improves type inference on by separating the seed from the op (currying) 2014-11-03 22:06:01 +01:00
Konrad 'ktoso' Malawski
026feea69b +str #16191 adds Flow.concat(Source):Flow method 2014-11-03 15:31:13 +01:00
Patrik Nordwall
5e240367f8 +str #16093 Add missing runWith variant 2014-11-03 10:43:07 +01:00
Martynas Mickevičius
412003c11e !str #16066 rename connect to via/to 
* add missing implicit conversions for ~>
* tests for all combinations when using ~>
 2014-10-31 10:43:42 +02:00
Patrik Nordwall
7c0c618791 !str #16039 Remove old scaladsl, rename scaladsl2 
* and impl2, testkit2
* keeping io2 for now
 2014-10-28 14:20:19 +01:00
Konrad 'ktoso' Malawski
3a4c7404c7 +str #15736 Initial version of JavaDSL for akka-streams (NOT complete) 
Missing features are:
+ be able to use all junctions from Java
* re-think akka.stream.javadsl.japi (because variance)
+ better docs
+ enable all tests
+ Partial flow graph as well as GraphFlow tests
+ enabled more FlowTest tests
+ fixed naming of internal classes (no Java in class names)
+ added converters for UndefinedSink/Source
 2014-10-10 17:04:18 +02:00
Patrik Nordwall
935559e3a7 +str #15079 Add flexible merge 2014-10-10 12:40:38 +02:00
Viktor Klang
e2eee49c2d =str - #16048 - Switches to pattern-matching iso getOrElse to avoid allocation in ThunkTab and Flow.apply 2014-10-09 11:18:30 +02:00
Endre Sándor Varga
3a60ed96d1 !str #15604: Removal of default fanout behavior 2014-09-04 15:49:14 +02:00
Patrik Nordwall
2ef9962eb0 !str #15026 change thunk publisher api to () => Option[T] 2014-08-29 08:32:57 +02:00
Patrik Nordwall
9dd281428d =str #15026 add some scaladoc backticks 2014-08-29 08:15:52 +02:00
Patrik Nordwall
85b85b4d75 =str #15026 take drop negative 2014-08-29 08:15:44 +02:00
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
Patrik Nordwall
1bb5d37780 !str #15551 Switch to implicit passing of FlowMaterializer 
* implicit param
* change tests to use implicit materializer
* add ActorFlow trait that provides an implicit materializer inside an actor
  in the right way, i.e. encourage usage of that instead of
  implicit def mat(implicit arf: ActorRef): FlowMaterializer
* make http compile, but those who know the api better will have to adjust
  to take full advantage of the implicit materializer
 2014-08-21 13:40:43 +02:00
Alexey Romanchuk
edf59b1cd4 +str #15558 Initial delay support for TickProducer 2014-08-21 12:35:46 +07:00
Patrik Nordwall
2c7fd89479 +str #15408 Replace uncheckedVariance annotations in Flow/Duct 2014-08-20 08:39:17 +02:00
Patrik Nordwall
bf3551b554 Merge pull request #15673 from akka/wip-15076-foreach-patriknw 
!str #15076 Make foreach a terminal operation, returning Future[Unit]
 2014-08-20 08:08:39 +02:00
Patrik Nordwall
0f2f5b3f89 Merge pull request #15562 from akka/wip–rename-tee-to-broadcast-√ 
= str - Renames Flow and Duct 'tee' operation to 'broadcast'
 2014-08-20 07:48:57 +02: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
Viktor Klang
6c7dc10a50 = str - #15618 - Renames Flow and Duct 'tee' operation to 'broadcast' 2014-08-05 10:47:42 +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
Mathias
a785eaf94d =str Improve merge signature 2014-06-10 22:25:03 +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
Endre Sándor Varga
50ab214d25 +str #15081: Implement conflate, expand and buffer 2014-05-23 12:07:25 +02:00
Endre Sándor Varga
a99902077e +str #15088, #15200: Add takeAndTail and concatAll 2014-05-22 15:19:18 +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
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
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
c62bbcdb68 Merge pull request #15146 from akka/wip-15106-flow-collect-patriknw 
+str #15106 Add Flow collect operator
 2014-05-12 11:10:37 +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
9b873b728b +str #15106 Add Flow collect operator 2014-05-08 09:32:38 +02:00
Patrik Nordwall
ab9b6ea023 +str #15105 Add Flow tee 2014-05-07 14:21:15 +02:00
Patrik Nordwall
9cf563af3f Merge pull request #15074 from akka/wip-15073-flow-produceTo-patriknw 
+str #15073 Add Flow produceTo consumer
 2014-05-07 14:00:25 +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
6c3985f1c5 +str #15073 Add Flow produceTo consumer 
* Fixes #15073
* Only sugar on top of toProducer produceTo
 2014-04-29 15:53:06 +02:00
Roland Kuhn
11125c9893 !str clarify the semantics of splitWhen 2014-04-16 17:12:39 +02:00
Patrik Nordwall
a318676f4a !str Rename ProcessGenerator to FlowMaterializer 2014-04-16 17:12:21 +02:00
Patrik Nordwall
907765fc24 !str Add onClomplete to Flow DSL 2014-04-16 17:12:19 +02:00
Patrik Nordwall
274e1267e5 !str Add cleanup function to transform 2014-04-16 17:12:14 +02:00
Patrik Nordwall
39dd4164b5 !str Align construction of thunk and collection producers 
* The user doesn't have to specify generator twice
 2014-04-16 17:12:12 +02:00