Commit graph

956 commits

Author SHA1 Message Date
虎鸣
c354aa0b6a =doc using java.time.Duration for stream's javadsl 2018-03-21 11:29:11 +08:00
Jimin Hsieh
3685ce619e Remove some of Unused import warning (#24750)
* Remove `Unused import` of `akka-actor-typed`

* Remove `Unused import` of `akka-actor-typed-tests`

* Remove `Unused import` of `akka-stream-tests`

* Remove `Unused import` of `akka-persistence`

* Remove `Unused import` of `akka-persistence-typed`

* Remove `Unused import` of `akka-cluster-typed`

* Remove `Unused import` of `akka-cluster-sharding-typed`

* Format source code
2018-03-20 12:01:15 +09:00
Konrad `ktoso` Malawski
6656b3c869
improve docs and test style of lazyInitAsync (#24754) 2018-03-20 00:04:34 +09: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
Christopher Hunt
e744e583e5 Capture the Success companion object as well as its class (#24747)
The absence of this is something that caught me out, and others.
2018-03-19 11:06:53 +09:00
Johan Andrén
d8b9bb1b3a
Java Flow dsl lower bounds incorrect #24368 2018-03-15 14:53:50 +01:00
Johan Andrén
a53a09e6ba
Subscribing twice should cancel second subscriber #24719 2018-03-15 13:55:33 +01:00
Konrad `ktoso` Malawski
563c7fbcf0 Issue 24594: Integration with sbt-headers and initial header population 2018-03-13 15:45:55 +01:00
Johan Andrén
d03d8fdd7e Subscription timeouts should not hit after stream ref subscribe #24626 2018-03-13 01:15:33 +09:00
Kevin Mas Ruiz
907c6a6931 Do not drop messages in delay with EmitEarly when buffer overflows (#24642) 2018-03-12 14:08:06 +01:00
Johan Andrén
f7637d24e6
Eliminate identity flow when possible #24554 2018-03-12 12:14:40 +01:00
Konrad `ktoso` Malawski
5be3c7bf83
parity for Sink, for preMaterialize operation (#24657)
* +str #24656 parity for Sink, for preMaterialize operation

* add java test

* added docs to stages-overview
2018-03-08 13:02:17 +09:00
Roman Filonenko
0ecadf7235 deduplicate logic for IODispatcher #24604 (#24619)
* deduplicate logic for IODispatcher #24604
 * introduce a resolveDispatcher helper in ActorAttributes
 * mention akka.stream.materializer.blocking-io-dispatcher instead of akka.stream.blocking-io-dispatcher in scaladocs
 * fix a flaky test
 * cosmetic changes in the touched files

* move resolveDispather helper to the Dispatcher companion object under a new name resolve

* filter out mima warning

* fix mima excludes after the 2.5.11 release

* address review comments
 * update stream-io.md with the correct dispatcher config key
 * mark ActorAttributes.Dispatcher#resolve as internal API
 * use the dispatche config key in ActorMaterializer

* add private[akka] to the resolve methods
2018-03-07 15:12:34 +01:00
kerr
97ca714d17 = all remove semicolons "bye-bye semicolon" (#24659) 2018-03-06 09:53:28 +09:00
Yan Su
519e6ae546 Add java duration support for Source.tick (Java DSL) #24339 (#24645) 2018-03-05 17:13:15 +01:00
Ignasi Marimon-Clos
3de7a4c27c Adds test and caps the timeout check period to 1s #24616 2018-03-01 11:47:02 +01:00
Johan Andrén
fd6f30673a Actually use the relative blocking io dispatcher setting #24357
* Remove docs and have only deprecation comment on old setting
* ConfigFactory.load fixed
2018-02-22 13:42:59 +01:00
Konrad Malawski
d6000df367 =str add simplified ask(ref) that defaults parallism 2 2018-02-22 19:50:46 +09:00
Konrad Malawski
4714f16dcf +str #18142 ask pattern integration for akka streams
progressed with cleanup, removing the same thread exec context is
weird... causes issues :-/ Need to debug more, could be that some race
also exists in mapAsync then :\

WIP

finish ask impl via watch stage

mima

consistency spec

fix paradox, and fix adding ask/watch to javadsl source

follow up review
2018-02-22 19:50:46 +09:00
gosubpl
edc67e0c3f +str Add Flow.lazyInit (#24427) (#24527) 2018-02-22 08:11:31 +01:00
Oleksii Tkachuk
80da4cadee Issue 24519: Created method lazilyAsync for both DSLs and adds section in docs (#24568)
* Issue 24519: Created method lazilyAsync for both DSLs and adds section in docs.

* Issue 24519: Changes according to code review

* Issue 24519: Added unit tests

* Update LazilyAsyncSpec.scala

* Issue 24519: Added copyright
2018-02-22 10:15:25 +09:00
Patrik Nordwall
9a13704969
Merge pull request #24577 from 2m/wip-fileio-exception-2m
#23951 Fail materialized future of IO stages when stream fails
2018-02-21 13:41:16 +01:00
Stefano Bonetti
3ea59b1e76 Adding preMaterialize operator for Source #23894 (#24497) 2018-02-21 15:06:01 +09: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
Martynas Mickevičius
24fd986aca
#23951 Fail materialized future of IO stages when stream fails 2018-02-20 18:05:08 +02:00
Martynas Mickevičius
357f5e62a4 #24411 Give a bit more time to the consumers (#24545) 2018-02-19 10:23:08 +01: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
Albert Serrallé Ríos
7630939b18 Cancel GroupBy when all substreams cancel (#24438) 2018-02-12 09:59:19 +01:00
Roman Filonenko
acf8b1b27b throw NoSuchFileException if the file is not there on FileIO.fromPath #24512 (#24513)
* replace deprecated expectNoMsg with expectNoMessage in the test
2018-02-08 09:18:35 +01:00
shkoder
1e7608d715 add JsonFraming usage example to the docs #24495 (#24498)
* add JsonFraming usage example to the docs #24495

* Update stream-io.md
2018-02-05 13:41:20 +01:00
Johannes Rudolph
f1aa12daf2 Port WithLogCapturing + Silence TLSSpec (#24476)
* =tkt port WithLogCapturing from akka-http

* =str use WithLogCapturing for very noisy TLSSpec

* =sha use WithLogCapturing to silence noisy CoordinatedShutdownShardingSpec
2018-02-02 09:50:28 +09:00
Patrik Nordwall
23fa8b0810 change spelling of behaviour to behavior, #24457 2018-02-01 15:10:46 +01:00
Martynas Mickevičius
cbe0215c41 Typed stream adapters, #23604
* Change more general factories to private
* Typed Streams docs
* Remove BoxedUnit from Java Api
* Use JavaPartialFunction in Java examples
* Doc wording improvements, formatting fixes, no verification diagrams
2018-01-31 15:33:48 +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
Patrik Nordwall
40018809f1
Merge pull request #24441 from nachinius/wip-24421-add-restartflow-with-backoff-only-on-failures
Adds RestartFlow to restart only on failures #24421
2018-01-30 11:02:54 +01:00
Ignacio (nachinius) Peixoto
e73434796c Adds RestartFlow to restart only on failures #24421 2018-01-29 13:58:31 -03:00
Johannes Rudolph
a1d8a5554b
Merge pull request #24354 from anilgursel/24353-groupBy-drops-new-group-anilgursel
groupBy pulls upstream when a substream materialization is waiting #2…
2018-01-25 11:41:18 +01:00
Anil Gursel
7b09a3e5e9 groupBy pulls upstream when a substream materialization is waiting #24353 2018-01-22 16:00:25 -06:00
Viktor Klang (√)
e999d03e8b The most common partition-case, as divertTo(Mat) #24388 2018-01-22 19:17:41 +01:00
Konrad Malawski
6264f8ea70 +str #24229 back to Future[] API for stream refs
nitpicks
2018-01-23 02:27:10 +09:00
Konrad Malawski
c5a2785c7c +str #24229 implement flattening of mat values, may block; SHOULD BE INTERNAL API
add java documentation

images
2018-01-23 02:27:10 +09:00
Konrad `ktoso` Malawski
7c75abbf7e +str #24229 move SinkRef / SourceRef to akka.stream
+str #24229 remove protobuf changes, which do not need to be made in this PR

docs

moved things

config object

subscription timeout confifmed working, also, attributes

document attributes for sub timeout

tests for the source also failing when it should

additional demand test

implemented protection from materializing "in cycles"; would be nice in
types but that breaks the niceness of use of the types
SinkRef/SourceRef...

cleanup

no idle timeout built in, can use the Timeout stages

more docs

simplest change to prevent exposing SinkRef => SourceRef => SinkRef cycle

Things to decide:
 * is it ok to require using `getSource` / `getSink` as Java API, is there better naming?
 * where should the constructors go? I'd say just in regular javadsl/scaladsl `Source`/ `Sink` objects

move constructors to {javadsl,scaladsl}.{Source,Sink} companion objects

Remove now useless "canMaterialize" field

Separate stage (implementation) from ref (wrapped actor ref) to make it clearer what is serialized

Clarify that partner refs are not optional in on-the-wire interfaces

minor cleanup in SourceRefStage

Renamed the stages but questionable if that really helps ;)

cleanups, better docs

cleanup, fix docs compilation

fix mima

got rid of Futures in the materialized values of stream refs
2018-01-23 02:27:10 +09:00
Konrad `ktoso` Malawski
682b047ac3 +str #24229 first working SinkRef, though serialization is wrong somehow (when serialize-messages = on)
silly serialization mistake, should have fixed serialize as well

tage actors now can have names, which helps a lot in debugging

thread weirdness

make sure to fail properly, actually go over remoting

issue with not receiving the SinkRef... what

initial working SinkRef over remoting

remote Sink failure must fail origin Source as well

cleaning up and adding failyre handling

SinkRef now with low-watermark RequestStrategy

source ref works, yet completely duplicated code
2018-01-23 02:27:10 +09:00
Patrik Nordwall
e4dd3c24fc add maxRestarts to RestartWithBackoff #24129 2018-01-16 18:28:10 +01:00
Johan Andrén
32987c8704
Simpler tls over tcp #24153 2018-01-16 18:05:08 +01:00
Johan Andrén
3cafdc65e0 Cleanup of UnfoldResourceAsync and fix for #24119
* More complete test coverage plus one found bug fixed
2018-01-16 15:01:55 +01:00
Johan Andrén
df40ef7bc0
Actually check the shutdown status before materializing anything (#24307) 2018-01-16 09:10:21 +01:00
Martynas Mickevičius
a3ae494325 #24104 Give a bit of time for consumers to register 2018-01-11 20:02:05 +09:00
Johan Andrén
4dde0742d0 Untangle settings from attributes in materializer #24063
Instead of renaming - deprecating and documenting

Renaming defaultInitialAttributes to defaultAttributes and adding docs

Tests passing

More work on using attributes for the attribute settings in ActorMaterializerSettings

Mark some attributes as mandatory and provide a smoother access w/o allocation for those

Another warning notice

MiMa filters

Part of the review adressed

Incorrect rebase fixed + formatting

Review feedback adressed

Formatting ...
2018-01-11 14:14:38 +09:00