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

101 commits

Author SHA1 Message Date
hepin1989
998c5a9285 Formatting java codes with sbt-java-formatter. 2019-01-12 04:00:53 +08:00
kerr
bdc90052aa Update headers from 2018 to 2019 once for all. (#26165) 
* Add CopyrightHeader support for sbt-boilerplate plugin.
* Add CopyrightHeader support for `*.proto` files.
* Add regex match for both `–` and `-` for CopyrightHeader.
* Add CopyrightHeader support for sbt build files.
* Update copyright from 2018 to 2019.
 2019-01-02 11:55:26 +01:00
kerr
fafc59b19d update headers to regular comment (#25807) 2018-10-29 05:19:37 -04:00
Guy Youansi
a4951e0ce7 Java time duration support for javadsl #24646 
java.time.Duration support in all jdocs java file, the persistence module and the distributed-data
 2018-06-26 15:41:30 +02:00
Tim Moore
5c401584c3 Add static import convenience methods to Done and NotUsed (#25174) 
* Add Done.done() convenience for static import
* Add NotUsed.notUsed() convenience for static import
 2018-05-31 13:12:20 +01:00
Jimin Hsieh
7c3a8a8ed5 java.time.Duration APIs in javadsl.TestKit #24646 2018-05-29 12:17:48 +02:00
Song Kun
55fb092bb2 Add convenient version of recover, recoverWith and recoverWithRetries for javadsl.Flow (#25036) 
* Add more convenient version of recover, recoverWith and recoverWithRetries for javadsl.Flow.

* The new method take a Class parameter to decide which failure to recover from.
* Also add corresponding unit tests for them.

* use case expression to express partial function

* make time out larger in unit test

* checkstyle

* fix parameter type
 2018-05-13 19:15:00 +02:00
虎鸣
c354aa0b6a =doc using java.time.Duration for stream's javadsl 2018-03-21 11:29:11 +08:00
Stefan Wachter
3db145643a materialized value of Flow.lazyInit must be a Future #24670 (#24685) 
* change materialized value of LazyFlow from [M] to Future[Option[M]]

* remove whitespace

* improve docu

* restore old Flow.lazyInit method and add new Flow.lazyInitAsync method

* fix deprecation messages

* add 2.5.11.backwards.excludes because of changed LazyFlow constructor signature

* check switching behaviour

* apply formatting

* improve deprecation message; improve null safety

* prevent premature stage completion by setting keepGoing

* deprecate Sink.lazyInit; add Sink.lazyInitAsync

* apply formatting

* add ProblemFilter.exclude for changed LazySink.this

* Update Sink.scala

* Update Sink.scala

* Update Flow.scala

* Update Flow.scala
 2018-03-19 22:42:37 +09: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
gosubpl
edc67e0c3f +str Add Flow.lazyInit (#24427) (#24527) 2018-02-22 08:11:31 +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
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
Patryk Najda
fe4c376a5e javadsl should use java types #23251 2017-07-03 13:39:00 +01:00
Hawstein
b3d00afdd1 Move ConstantFun to akka.util, #22813 2017-05-10 18:00:42 +02:00
Arnout Engelen
78b5ed8498 Re-enable javadsl Flow 'via' test #18863 2017-04-26 07:24:41 +02:00
Patrik Nordwall
c3c058b6bb Merge pull request #22360 from johanandren/wip-21363-future-source-last-bit-johanandren 
Source that flattens a future source and keeps mat val
 2017-03-16 20:36:05 +01:00
Hawstein
6434cbe868 Re-implement javadsl testkit (#22240) 
* re-implement javadsl testkit

* fix mima problem

* rebase master

* move ImplicitSender/DefaultTimeout to scaladsl

* undo the change of moving scala api

* fix return type and add doc

* resolve conflicts and add more comments
 2017-03-16 20:02:47 +01:00
cchantep
5b542d99fa Flatten a Future[Graph[SourceShape[T], M]] as Source[T, Future[M]] #22359 2017-03-14 12:54:01 +01:00
Philippus Baalman
6c7085252a extended copyright into 2017 2017-01-04 17:37:15 +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
Endre Sándor Varga
5e830323f6 Updating to ScalaTest 3.0.0 and ScalaCheck 1.13.2 2016-08-22 11:13:49 +02:00
Patrik Nordwall
be448e9fbb fix memory leaks in tests, #20659 2016-05-31 08:51:00 +02:00
Roland Kuhn
45e97e8467 remove akka.stream.testkit.AkkaSpec, fixes #19879 2016-02-25 15:26:51 +01:00
Johan Andrén
62e30b3c08 Update copyrights and links to the new company name #19851 2016-02-23 12:58:39 +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
drewhk
ebb915ae4d Merge pull request #19750 from lolski/lolski-issue-19293-rebased 
=str #19293 fix issues in Sink.seq + minor doc fixes + use Sink.seq
 2016-02-12 11:36:56 +01:00
Alexander Golubev
2a36859578 =str #19423 add satefulMapConcat 2016-02-11 22:57:50 -05:00
drewhk
3d9ea4415f Merge pull request #19648 from agolubev/agolubev-#18045-add-recoverWith(Source) 
+str #18045 add recoverWith(Source)
 2016-02-11 20:34:53 +01:00
lolski
21381d5710 =str #19293 fix issues in Sink.seq + minor doc fixes + use Sink.seq and limit in tests where appropriate 
* Sink.seq (Scala DSL) now returns immutable.Seq rather than Seq
* Sink.seq will not silently truncate when incoming elements is > Int.MAX_VALUE
* minor doc fixes
* replacing various grouped(n) / Sink.head with limit(n) / Sink.seq in various tests
* fix inconsistent indentation in RequestParserSpec
 2016-02-12 01:36:21 +08:00
Alexander Golubev
5a8f4135b7 +str #18045 add recoverWith(Source) 2016-02-11 10:36:40 -05:00
Alois Cochard
6c69fba61e 19452: Contramap and fromFunction 2016-02-11 15:32:48 +01:00
Endre Sándor Varga
3081e2895b 19455 Simplify conflate signature for the common case 2016-02-04 16:06:23 +01:00
Johan Andrén
f008a932c3 Merge pull request #19603 from akka/wip-19068-2016-copyrights-johanandren 
=pro #19068 All copyrights ranges updated with 2016
 2016-01-25 12:07:42 +01:00
Roland Kuhn
d49d2545ec convert watchTermination to CompletionStage for Java 2016-01-25 11:14:31 +01:00
drewhk
41d8b1fadd Merge pull request #19498 from agolubev/agolubev-#18565-TerminationNotification-combinator 
+str #18565 termination notification combinator
 2016-01-25 10:52:48 +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
98c72e7d13 +str #18565 termination notification combinator 2016-01-22 16:45:54 -05:00
Roland Kuhn
53ad1085ec Merge pull request #19548 from akka/wip-19522-asPublisher-enum-RK 
#19522 make javadsl.Sink.asPublisher nicer
 2016-01-21 16:57:34 +01:00
Roland Kuhn
9427052fd0 #19522 make javadsl.Sink.asPublisher nicer 2016-01-21 16:57:21 +01: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
Roland Kuhn
e5baba2b29 squash some warnings 2016-01-20 11:54:24 +01:00
Roland Kuhn
7463c50fc9 #19444 simplify signature of FlowOps.expand 
Any previous usage can be represented in this fashion while typically
saving one function allocation and also saving the function literal’s
syntax overhead (for the seed). Plus a new feature: the provided
iterator does not have to be infinite, limiting how far expand is
allowed to go.
 2016-01-20 09:27:45 +01:00
Endre Sándor Varga
60497f6561 also fix FlowInterleaveSpec 
Also-by: Johan Andrén <johan@markatta.com>
Also-by: Roland Kuhn <rk@rkuhn.info>
Also-by: Martynas Mickevičius <mmartynas@gmail.com>
 2016-01-20 10:01:58 +02:00
Roland Kuhn
8a5a420108 #19261 override and test addAttributes compilation 2015-12-22 20:56:02 +01:00
Iain Monro
52655f2836 +str #19069 Add FlowOp.prepend for prepending Sources to Flows 2015-12-20 09:55:45 +01:00
Martynas Mickevičius
e6e476d82a =str #19128 #19127 rename Source/Sink factory apply overloads 2015-12-17 11:48:30 +02:00