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

93 commits

Author SHA1 Message Date
Richard Imaoka
75723dcf4f Correct timeout 2018-08-25 09:26:43 +09:00
Richard Imaoka
c12eb92e55 Formatting, and use java.time.Duration 2018-08-23 23:40:16 +09:00
Richard Imaoka
52864ffb28 Add the pipe pattern section (#23948) 2018-07-28 23:57:15 +09:00
Roman Filonenko
4a8368bfe0 remove unreferenced akka-docs/src/test/*/tutorial_6 (#25363) (#25364) 2018-07-19 15:22:10 +09:00
Chang Liu
862a66ecc7 Add docs and example for akka-stream operator from (#24933) (#25372) 
* Add docs and example for akka-stream operator from (#24933)

* add seperate test class for code example of akka-stream from

* add copyright header
 2018-07-19 13:38:47 +09:00
Mikko Östlund
46b433b47d Align Java sample DeviceGroupQueryTest with the Scala one #25278 2018-07-03 17:39:12 +02:00
Patrik Nordwall
02f6899952 example for Streams log operator (#25283) 
* and added all log levels in Attributes for convenient single access point
 2018-06-30 12:10:10 +09: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
Jimin Hsieh
7c3a8a8ed5 java.time.Duration APIs in javadsl.TestKit #24646 2018-05-29 12:17:48 +02:00
Richard Imaoka
a17a61557c doc Replace the word stage by operator in stream doc (#25138) 2018-05-29 10:00:48 +02:00
Konrad `ktoso` Malawski
de04758bb8 more docs for Sink.queue and actorRefWithAck (#25063) 2018-05-22 11:27:54 +02:00
Arnout Engelen
9869c2355e
Fix Java Doc test for actorRefWithAck (#25079) 2018-05-15 11:52:07 +02:00
Johan Andrén
09025092ae Remove words such as simply and obviously from docs (#25095) 
* One does not "simply"

* It's not obvious

* It's not really _that_ easily done

* Basically is basically a useless word

* Of course - if you already know how things work you wouldn't be reading the docs

* Clearly is maybe not so clear for everyone

* Just was just a bit harder as there are some uses that are just
 2018-05-15 07:11:03 +01:00
Guy Youansi
759010f0cd +act add java.time.Duration support Actor javadsl (#24993) 
* add java support in akka-actor module in the class Abstract.ActorContext by adding the setReceiveTimeout and CancelReceiveTimeout

* add akka.actor.AbstractActor#ActorContext cancelReceiveTimeout and setReceiveTimeout to mima-excludes file

* removed scala.concurrent.duration dependency in ActorDocTest and add new method expectTerminated with java.time.Duration support in TestKit

* used java.time.Duration as default import
 2018-05-14 17:22:02 +09:00
Konrad `ktoso` Malawski
d870d37bb3 =doc missing ACK reply in doc example (#24997) 2018-04-30 14:12:04 +02:00
Richard Imaoka
e343222505 Sample code for joinSeedNodes programatically #24041 2018-04-30 10:21:35 +02:00
Konrad `ktoso` Malawski
046b88ce90
+doc Add examples to Sink.actorRefWithAck (#24854) 2018-04-12 22:06:37 +09:00
Patrik Nordwall
6a9fa1946d
Add java.time.Duration support in the JavaDSL in akka-actor module #24646 (#24883) 
* Add java.time.Duration support in the JavaDSL in akka-actor module #24646
* add deprecation and change retry
 2018-04-11 16:47:36 +02:00
Patrik Nordwall
6f330ef69c automatic throttle burst size, #24699 (#24784) 
* automatic throttle burst size, #24699

* throttleEven used maxBurst=Int.MaxValue, which in practise resulted
  in no throttling at all at high rates
* The original problem that throttleEven tried to solve was that when
  the throttle rate (cost / per) was high the cost of scheduling
  dominated and became much lower than the given rate, if 0 or low
  maxBurst was given. Difficult for user to know what maxBurst to use.
* In fact, that was already the case for rates > 30/s.
* This is fixed by automatically adjusting the maxBurst for higher
  throttle rates in a new throttle overload that doesn't include
  maxBurst parameter
* Also skipped the mode parameter for that variant since Shaping is
  what almost always is what you want, and otherwise you can use
  the full signature with a good maxBurst
* Deprecated throttleEven, since it is the same. Also fixed the
  implementation of throttleEven to use the automatic burst size,
  since Int.MaxValue is not useful at all.
 2018-04-02 15:07:16 +01:00
mikolak-net
00068e2d1d Extrapolate stage and expand redoc #23804 2018-03-27 10:39:25 +02:00
Gergő Törcsvári
67a81eb01b GraphDSL create with Seq[Graph] added #24067 2018-03-26 17:41:54 +02:00
Daniel Kalman
86e44167f3 Added retry pattern #22276 (#23997) 2018-03-26 13:56:20 +02:00
Prada Souvanlasy
46c662965f fix #23618 : Support for persistence dynamic configuration at runtime (#23841) 2018-03-26 13:52:31 +02:00
Patrik Nordwall
11f2ef5784
Merge pull request #24508 from psliwa/patch-1-defer-method 
Adding defer method to PersistentActor
 2018-03-21 13:41:51 +01:00
Patrik Nordwall
b34c38e37e
Merge pull request #24755 from hepin1989/javadocs 
=doc using java.time.Duration for stream's javadsl
 2018-03-21 13:36:14 +01:00
虎鸣
c354aa0b6a =doc using java.time.Duration for stream's javadsl 2018-03-21 11:29:11 +08:00
虎鸣
e45a638ce0 + testkit Add java.time.Duration to testkit's javadsl 2018-03-20 22:39:30 +08:00
kerr
8245c55bc9 + str Add java.time.Duration to TimerGraphStageLogic. (#24712) 2018-03-19 14:04:44 +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
Roman Filonenko
8fcf728b7a fix Trigger references in the stream cookbook example for digest #24317 
* replace Trigger with Unit
 * cosmetic changes in docs.stream.cookbook tests
 2018-03-03 08:52:02 +01: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
Stefano Bonetti
3ea59b1e76 Adding preMaterialize operator for Source #23894 (#24497) 2018-02-21 15:06:01 +09:00
piotr.sliwa
2f6deace13 Adding defer method to PersistentActor 2018-02-20 23:30:56 +01:00
Konrad `ktoso` Malawski
8d1feb5a10
fix java documentation snippet by being explicit (#24569) 
* fix java documentation snippet by being explicit

* Update FaultHandlingTest.java

* Update FaultHandlingTest.java

* Update FaultHandlingTest.java
 2018-02-20 18:07:40 +09:00
Ryan C. Hill
acbf1ce7b5
Deprecated method used in docs 
Updated example code to use the alternative method provided in v2.5.0
 2018-02-16 16:15:13 -07:00
Christopher Batey
eede5533ac
Chunker should only pull if buffer is empty (#24019) 
For the current Chunker if the upstream sends larger messages than the
chunk size the buffer can slowly fill up until the app OOMs. Change it
so it only pulls if the buffer is empty
 2018-02-14 16:18:58 +00:00
Arnout Engelen
f2e39c7534 Add example of testing actors with subclassing (#24539) 2018-02-13 19:29:30 +01:00
Richard Imaoka
b3a27d1c9f Add log() in stream-error.md (#24522) 
* Add log() in stream-error.md (#23722)
 2018-02-12 14:30:54 +00:00
Johan Andrén
cb048457c8
StreamTcpDocSpec: Less race, better error if client fails #24500 2018-02-12 14:42:52 +01:00
Johan Andrén
4cde6e7feb Less fragile way of waiting for stream completion #24501 (#24528) 2018-02-12 14:38:22 +01:00
Christopher Batey
6c7839f937 Testkit docs use deprecated messages (#24472) 
We also had a deprecated method without implementing
the alternative
 2018-02-02 18:12:01 +09:00
Konrad `ktoso` Malawski
c023d51367
=doc #24435 copy mutable maps before sharing them as messages in java (#24447) 
* =doc #24435 copy mutable maps before sharing them as messages in java

* fix rename

* Update DeviceGroup.java

* Update DeviceGroup.java
 2018-01-30 23:20:15 +09:00
Arnout Engelen
c05dd26700 Use getWhenTerminated in Java examples (#24428) 
* Use getWhenTerminated in Java examples

Introduced in #24330

* Fix compilation error
 2018-01-29 18:05:11 +09: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
Patrik Nordwall
e4dd3c24fc add maxRestarts to RestartWithBackoff #24129 2018-01-16 18:28:10 +01:00
Catalin Ursachi
2360de583d Add streams recipe for 'source from function' (#22074) (#24132) 2018-01-16 15:29:03 +01:00
Christopher Batey
009214ae07
Update copyright to 2018 (#24241) 2018-01-04 17:26:29 +00:00
kerr
7edf3bfecf + actor #15446 add external predicate to ReceiveBuilder (#24221) 2018-01-03 10:23:31 +01:00