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

65 commits

Author SHA1 Message Date
Jimin Hsieh
2c2b8ba001 Remove some of Unused import warning (#24650) 2018-03-16 12:08:29 +01:00
Johan Andrén
d8b9bb1b3a
Java Flow dsl lower bounds incorrect #24368 2018-03-15 14:53:50 +01:00
Konrad `ktoso` Malawski
563c7fbcf0 Issue 24594: Integration with sbt-headers and initial header population 2018-03-13 15:45:55 +01:00
虎鸣
e44fafd4b7 + stream add collectType operator to Source,SubSource,Flow and SubFlow for javadsl. 
add docs for collectType, do mirror it in scaladsl

mima
 2018-02-21 14:23:11 +09:00
jeremystone
e766207a87 alsoTo eager cancellation #24291 2018-02-19 08:31:13 +01:00
Catalin Ursachi
ccf5d46a58 Add wireTap combinator (#15077) (#23824) 2018-02-13 20:39:00 +01:00
Patrik Nordwall
23fa8b0810 change spelling of behaviour to behavior, #24457 2018-02-01 15:10:46 +01:00
Viktor Klang (√)
08b0d34a4c Introduces eager cancellation for divertTo 
* and updates Partition to support this behavior
* not adding Partition.apply overload due to type inference issues, use constructor instead
 2018-01-30 19:59:53 +01:00
Viktor Klang (√)
e999d03e8b The most common partition-case, as divertTo(Mat) #24388 2018-01-22 19:17:41 +01:00
Christopher Batey
009214ae07
Update copyright to 2018 (#24241) 2018-01-04 17:26:29 +00:00
Alexander Golubev
a7b1a6675b Add throttle combinator without bucket size in parameters (#23808) 
* +str Add throttle combinator without bucket size in parameters

* Add mima filter plus comment formatting

* Reviwed throttle messages across all classes

* move mima filter to 2.4.6

* change to throttleEven, plus grammar fixes

* fix formatting

* changed mima filter according to new API

* fixes accoring to feedback
 2017-11-17 12:20:12 +01:00
Johan Andrén
407131cb4e Stream supervision doc clarification #23376 2017-07-26 16:23:46 +02:00
Patryk Najda
fe4c376a5e javadsl should use java types #23251 2017-07-03 13:39:00 +01:00
Richard Imaoka
4f10d45376 Correct the backpressure API comment for buffer 2017-06-28 00:07:19 +09:00
Richard Imaoka
c636f3540f Correct the backpressure API comment for throttle (Fixes #22791) (#23225) 2017-06-27 05:32:53 -07:00
Konrad `ktoso` Malawski
b7d7316c1c =str #22917 recoverWithRetries allow 0 and negative values 2017-06-13 11:18:46 +02:00
Hawstein
b3d00afdd1 Move ConstantFun to akka.util, #22813 2017-05-10 18:00:42 +02:00
Gilad Hoch
edee4ba409 +str #22711 adding GroupedWeightedWithin 2017-04-28 15:07:06 +02:00
Konrad `ktoso` Malawski
205a538df3 =act,str Port be-scala-2.13-friendly (#22528) 
* !str #22527 fix SubSource/SubFlow.zip Pair type

* =act don't use conforms, be scala 2.13 friendly

* Update SubFlow.scala
 2017-03-13 12:39:57 +01:00
Philippus Baalman
6c7085252a extended copyright into 2017 2017-01-04 17:37:15 +01:00
Konrad Malawski
e7e1f74427 =str more specific error type if idle-timeout triggers in tcp 2016-12-14 12:39:24 +01:00
Konrad Malawski
04ab4ebb9c -str #21423 remove deprecated Stage references (#21919) 
* -str #21423 remove deprecated Stage references

* include mima filters for removed classes
 2016-12-02 14:23:13 +01:00
Falmarri
a28d2c579f Added a flag on takeWhile to allow it to include the final element, #21330 2016-10-18 12:02:59 +02:00
Mateus Dubiela Oliveira
c3abde60d5 Add scanAsync to Akka Streams, similar to scan but taking a Future (#21553) 
* Add comprehensive tests
* Add documentation

* Damn comma after rebase

* Add documentation for foldAsync and scanAsync

* Rename aggreator and aggreating to current

* Remove out availability check

* Revert removing out and some refactors

* Formatting documentation

* Use after instead of Promise in test

* Use package reference to after and some refactoring
 2016-10-17 16:43:11 +02:00
Stefano Bonetti
0f71b841b5 Include parallelism in mapAsyncUnordered docs #21556 2016-10-04 15:18:08 -05:00
Nafer Sanabria
94d7237d17 +str add zipWithIndex to FlowOps #21290 2016-09-21 08:41:56 +02:00
Johan Andrén
012919fdb3 OrElse stage for fallback when no elements emitted #21024 2016-08-30 13:35:59 +02:00
Cédric Chantepie
efc87af58a FoldAsync op for Flow #18603 2016-08-24 21:02:32 +02:00
Björn Antonsson
c66ce62d63 Update to a working version of Scalariform 2016-06-02 22:12:36 +02:00
Robert Budźko
8534adf603 Introduced backpressure timeout (#20131) stage. 2016-05-06 12:57:27 +02:00
David Knapp
d7fe98e1c4 #20123 Added recoverWithRetries which adds a parameter to limit the (#20137) 
number of attempts. Existing recoverWith method behavior remains unchanged.
 2016-04-20 15:24:12 +02:00
Julian Tescher
af34554b19 Fix common typos 2016-02-25 09:42:10 -08:00
drewhk
664071afb6 Merge pull request #19835 from agolubev/19818-Flow.transform-deprected-agolubev 
=str #19818 Flow.transform should be deprected too
 2016-02-24 17:52:06 +01:00
Johannes Rudolph
b6cbc7f13a =all remove unused imports 2016-02-23 20:29:22 +01:00
Johan Andrén
62e30b3c08 Update copyrights and links to the new company name #19851 2016-02-23 12:58:39 +01:00
Alexander Golubev
c7c4ced93a =str #19818 Flow.transform should be deprected too 2016-02-22 15:48:14 -05:00
Konrad Malawski
ef827e6ef1 -htp #19577 replace overloads of bind with HttpConnect 2016-02-16 13:01:05 +01:00
Roland Kuhn
e202ea8c40 clean up dependencies #19755 and other fixes 
* remove inter-project dependencies between streamTestkit -> peristence -> remote
* make PartitionOutOfBoundsException extend IndexOutOfBoundsException
* some weird formatting
* remove -experimental from HTTP Testkit/Tests
* split out shared LevelDb journal tests into new subproject (not to be
  published)
 2016-02-15 20:35:37 +01:00
Alexander Golubev
f7d23b508b =str #18890 fix throttle 2016-02-12 09:14:41 -05:00
Roland Kuhn
7d0099e80a Merge pull request #19634 from agolubev/agolubev-#19423-add-statefulMapConcat 
=str #19423 add statefulMapConcat
 2016-02-12 11:00:48 +01:00
Roland Kuhn
d42b84327c Merge pull request #19754 from akka/wip-19732-async-RK 
nicer declarative .async boundaries and remove Module.nest()
 2016-02-12 10:46:32 +01:00
Alexander Golubev
2a36859578 =str #19423 add satefulMapConcat 2016-02-11 22:57:50 -05:00
Johan Andrén
4e49d75ad8 !str #19732 Concise and consistent way to mark async boundaries 2016-02-11 18:20:23 +01:00
Alexander Golubev
5a8f4135b7 +str #18045 add recoverWith(Source) 2016-02-11 10:36:40 -05:00
Endre Sándor Varga
3081e2895b 19455 Simplify conflate signature for the common case 2016-02-04 16:06:23 +01:00
Prayag Verma
b7783968a0 =pro #19068 All copyrights ranges and single years updated to a range ending in 2016 2016-01-25 10:20:30 +01:00
Roland Kuhn
4c72495581 #19440 replace Scala Future usage with CompletionStage in javadsl 
This entails:

  * adding akka.pattern.PatternCS.* to enable ask etc. with
    CompletionStage
  * changing RequestContext to offer an ExecutionContextExecutor for the
    CompletionStage.*Async combinators
  * splitting up akka.stream.Queue for JavaDSL consistency
 2016-01-23 18:00:11 +01:00
Alexander Golubev
a2ab7f29e1 +str #19020 reduce combinator 2016-01-21 22:16:37 -05:00
Gilad Hoch
fde0c11fff +str #16610 added javadsl tests + conflate now delegates to Batch + most of the changes @drewhk & @rkuhn suggested 2016-01-21 08:44:31 +02:00
Gilad Hoch
b420d6a472 +str #16610 applied the changes suggested by @drewhk 2016-01-21 08:44:30 +02:00