Richard Imaoka
c05a3e0e26
Fix Scaladoc for recoverWithRetries ( #23762 ) ( #23763 )
2017-10-30 16:21:44 +01:00
Patrik Nordwall
cd4ee59cc8
Add parameter eagerClose to Flow.interleave #22710 ( #23718 )
...
* overloaded methods added for binary compatibility
* Doc improve: remove unnecessary example, reword eagerClose description
* Test eagerClose = true when other stream closed
2017-09-25 23:26:54 +09:00
Johan Andrén
407131cb4e
Stream supervision doc clarification #23376
2017-07-26 16:23:46 +02:00
Konrad `ktoso` Malawski
6d74e8782b
+str,doc #23274 add ASCII diagrams for Flow.fromSinkAndSource ( #23277 )
2017-07-04 16:57:24 +02: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
Martynas Mickevičius
c840bd6f37
#22808 Move CoupledTerminationFlow to Flow.fromSinkAndSourceCoupled
...
Also mention coupled variant in the uncoupled scaladoc
2017-05-22 16:00:10 +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
Martynas Mickevičius
2a9c0370e0
Add @InternalApi annotations and private markers on internal apis ( #22563 )
...
* #22506 Mark materializer extension as @InternalApi
* #22506 Added missing annotations on internal apis in the fusing package
* #22506 Missing annotations in io package
* #22506 Add internal api annotations in impl package
* #22563 more hiding of the classes in the impl package
* #22563 Formatting fixes
* #22506 Fix private access in stream tcl tests
2017-03-16 20:04:07 +01:00
Patrik Nordwall
c7a05862c4
workaround for nested attribute issue, #22523
2017-03-10 17:05:33 +01:00
Patrik Nordwall
6c8e24cefa
fix SinkSpec, and async boundary attribute, #22463
...
* let's keep the AsyncBoundary attribute for now,
makeIsland is done in setAttributes
* fixing SinkSpec and RunnableGraphSpec
2017-03-08 15:09:40 +01:00
Endre Sándor Varga
ba63c7af8d
New materializer and layout
2017-03-01 16:18:55 +01:00
Patrik Nordwall
84ade6fdc3
add CoordinatedShutdown, #21537
...
* CoordinatedShutdown that can run tasks for configured phases in order (DAG)
* coordinate handover/shutdown of singleton with cluster exiting/shutdown
* phase config obj with depends-on list
* integrate graceful leaving of sharding in coordinated shutdown
* add timeout and recover
* add some missing artery ports to tests
* leave via CoordinatedShutdown.run
* optionally exit-jvm in last phase
* run via jvm shutdown hook
* send ExitingConfirmed to leader before shutdown of Exiting
to not have to wait for failure detector to mark it as
unreachable before removing
* the unreachable signal is still kept as a safe guard if
message is lost or leader dies
* PhaseClusterExiting vs MemberExited in ClusterSingletonManager
* terminate ActorSystem when cluster shutdown (via Down)
* add more predefined and custom phases
* reference documentation
* migration guide
* problem when the leader order was sys2, sys1, sys3,
then sys3 could not perform it's duties and move Leving sys1 to
Exiting because it was observing sys1 as unreachable
* exclude Leaving with exitingConfirmed from convergence condidtion
2017-01-16 09:01:57 +01:00
Konrad Malawski
5c79b81e92
+doc document DoNotInherit and ApiMayChange
2017-01-06 15:12:53 +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
kenji yoshida
aebfda540d
=doc fix double 'the' in some docs ( #21881 )
2016-11-22 02:14:37 +01:00
Hawstein
96a1d2a081
rewrite Buffer as a GraphStage #21528
2016-11-15 18:48:33 +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
Patrik Nordwall
359a087674
Merge pull request #21166 from naferx/sink-graphstage
...
=str rewrite Sink internal impl as GraphStage
2016-08-30 10:37:30 +02:00
Cédric Chantepie
efc87af58a
FoldAsync op for Flow #18603
2016-08-24 21:02:32 +02:00
Nafer Sanabria
2f85cf0fb8
=str fix up Scaladocs for Source & Sink
2016-08-11 14:37:54 +02:00
Nafer Sanabria
bed69d1002
=str rewrite Sink internal impl as GraphStage
2016-08-09 21:08:31 -05:00
Johan Andrén
61f566063b
named should not replace attributes #21068
...
Add attributes in named rather than replace, additionally: test coverage and missing method on RunnableGraph added
2016-08-09 15:11:59 +02:00
Adam Warski
033516b188
Adding ScalaDocs for FlowOps.async #21137
2016-08-08 16:11:59 +02:00
Endre Sándor Varga
5382014133
make Map a GraphStage
2016-08-01 11:31:07 +02:00
Tim Harper
1c6b38743b
make RunnableGraph.addAttributes return a RunnableGraph #20630
2016-07-29 15:04:26 +02:00
zhxiaog
9683e4bc58
migrate Fold, Sliding, Grouped to GraphStage ( #20914 )
2016-07-08 14:24:03 +02:00
Kam Kasravi
1d692daaad
Fixes #20543 GraphStage subtypes should not be private to akka
2016-07-05 17:12:35 -07:00
Michał Płachta
00c5f49c7a
Replace PushStage-based Log with GraphStage (part of #19834 ) ( #20788 )
...
* Replace PushStage-based Log with GraphStage (part of #19834 )
* Remove LogLogic and FilterLogic toStrings
2016-06-22 16:36:18 +02:00
Björn Antonsson
c66ce62d63
Update to a working version of Scalariform
2016-06-02 22:12:36 +02:00
Alexander Golubev
03395d5739
=str #20229 groupBy should be a Graph stage ( #20344 )
2016-05-23 10:31:49 +02:00
Samuel Tardieu
e0c64f59d8
=str #20550 only accept -1 for infinite retries in recoverWithRetries ( #20555 )
2016-05-19 11:45:31 +02:00
Robert Budźko
8534adf603
Introduced backpressure timeout ( #20131 ) stage.
2016-05-06 12:57:27 +02:00
Patrik Nordwall
dfbcd948bf
Merge pull request #20325 from akka/wip-convert-scan-to-graphstage-√
...
Converts the Scan-operation from PushPullStage to GraphStage
2016-04-20 15:37:16 +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
zhxiaog
7207189d6a
convert Recover to GraphStage
2016-04-18 15:23:05 +08:00
Viktor Klang
455805cda9
Converts the Scan-operation from PushPullStage to GraphStage
2016-04-15 10:51:24 +02:00
Michał Płachta
8376fa8cfd
Replace PushStage-based Filter with GraphStage (part of #19834 ) ( #20269 )
2016-04-14 11:04:08 +02:00
Konrad Malawski
b9ab232cac
str #20262 reduce should fail explicitly on empty stream ( #20267 )
...
* str #20262 reduce should fail explicitly on empty stream
* str #20262 document reduce behaviour on empty stream
2016-04-11 15:36:10 +02:00
Evgeny Vanslov
f42ab58b05
Replaced PushStage based TakeWhile with GraphStage #19834
2016-04-01 11:34:30 +03:00
Tal Pressman
26c25c89ed
+str #19390 Add 'monitor' flow combinator and stage
2016-04-01 08:06:37 +02:00
Endre Sándor Varga
d815ed1b5e
19862 Token bucket reimplemented
2016-03-31 11:36:03 +02:00
