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

22587 commits

This branch
This branch
All branches
Author SHA1 Message Date
Richard Imaoka
8f5ea03a6f Fix compilation errors and minor update to the futures.md 2018-07-29 00:41:09 +09:00
Richard Imaoka
52864ffb28 Add the pipe pattern section (#23948) 2018-07-28 23:57:15 +09:00
David Mischke
2737caf8fb use correct Source import 2018-07-27 17:51:00 +02:00
David Mischke
f543f69c93 Merge branch 'master' of https://github.com/akka/akka into document-stream-source-range-operator 2018-07-27 12:35:28 +02:00
Roman Niukhalov
6a1a09de17
Merge branch 'master' into fix-receive-timeout 2018-07-27 13:57:55 +07:00
kenji yoshida
5b3b191bac Remove procedure syntax (#25362) 2018-07-25 13:38:27 +02:00
Christopher Batey
8476a90d1f Remove use of deprecated methods in java docs 2018-07-25 09:50:19 +01:00
Guillaume Carlier
80fdff79a9
Merge branch 'master' into wip-25387-Balance-should-test-noPending 2018-07-25 10:22:36 +02:00
Seeta Ramayya
50979d599c added getScheduler and getDispatcher methods to ActorSystem #24900 2018-07-25 09:23:03 +02:00
Roman Niukhalov
500f0c2ddc
Merge branch 'master' into fix-receive-timeout 2018-07-24 23:20:39 +07:00
Carlier Guillaume
70aa175d6c Fix bug in Balance stage when some downstreams pull and close immediately and an another try to pull but wait a response indefinitely #25387 2018-07-24 17:58:42 +02:00
Christopher Batey
d8a47b6700
Switch order of javadsl EventHandler type params (#25354) 
Closes #25188
 2018-07-24 08:47:45 +01:00
Matteo Gazzetta
339fc3d48e Update dependencies and plugins (#25376) 
* Update dependencies
* Update plugins
* Downgrade aeron from 1.10.2 to 1.9.3 due to test failures
 2018-07-24 08:25:29 +02:00
David Mischke
f94733acc6 addressing review comments #24933 2018-07-23 13:07:32 +02:00
Roman Niukhalov
82afb80dcf
Merge branch 'master' into fix-receive-timeout 2018-07-21 23:05:38 +07:00
David Mischke
9885a56f17 Merge branch 'master' of https://github.com/akka/akka into document-stream-source-range-operator 2018-07-21 14:16:58 +02:00
David Mischke
80c0596733 improve Source.range docs #24933 2018-07-21 14:09:32 +02:00
Philippus Baalman
9fae4e2839 Add localized message from cause if message equals null (#25367) 2018-07-20 17:58:52 +09:00
Ikenna Darlington Ogbajie
fb9bb51dc7 Add examples in Scala documentation for Source.fromFuture #24933 (#25374) 
* Add scala documentation for Source.fromFuture #24933
 2018-07-20 07:17:05 +01:00
iyogi
3e698be9ce Add code sample for operator Source.single (#25375) 
* Add code example for Source.single
 2018-07-20 07:15:13 +01:00
Roman Niukhalov
bdd5d408e9
Merge branch 'master' into fix-receive-timeout 2018-07-19 16:06:02 +07:00
Seeta Ramayya
61790d763d Improved logging when node joins itself #25279 2018-07-19 10:26:28 +02:00
Gordon Cheung
1638580339 Added code example for the stream operator map (#25373) 
* Added code example for the stream operator map
 2018-07-19 08:15:17 +01: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
Konrad `ktoso` Malawski
f4fbbf9312
=typ #24725 disallow deferred behaviors as postStop hooks (#25123) 2018-07-19 10:26:01 +09:00
Giuseppe D'Alessio
578f32d322 Adding combine operator scala example #24933 (#25371) 2018-07-18 18:53:31 +02:00
David Mischke
598b22622d Adding documentation to Source.range method #24933 2018-07-18 18:49:47 +02:00
Roman Niukhalov
76caee2cf4
Merge branch 'master' into fix-receive-timeout 2018-07-18 23:48:52 +07:00
Philippus Baalman
3cf87a1c12 Remove duplicate 'for' in code comments (#25366) 2018-07-19 00:08:51 +09:00
Roman Niukhalov
129ead30d5
Merge branch 'master' into fix-receive-timeout 2018-07-18 21:08:05 +07:00
Roman Filonenko
3b8a448de2 fix broken link in akka-stream docs on ask #25358 (#25360) 2018-07-18 17:35:20 +09:00
Roman Niukhalov
4ffe9e3ad8
Merge branch 'master' into fix-receive-timeout 2018-07-16 14:17:02 +07:00
Christopher Batey
503811f634 Harden StreamTestKitSpec 
Closes #24956
 2018-07-16 06:21:54 +01:00
Song Kun
ac79f9b03d Fix broken links of CRDTs materials in "Learn More about CRDTs" (#25351) 
* Add a new link to "Strong Eventual Consistency and Conflict-free Replicated Data Types" and remove "Eventually Consistent Data Structures". fix #25338

* Update distributed-data.md
 2018-07-16 14:10:23 +09:00
lteqgt
ec7320a3c7 Fix java dsl for createLogLevels (#25337) 
* createLogLevels java dsl: remove ability to pass in nulls as default args since it's a bug

* fix scala doc for Java: [[Attributes#logLevelOff]] instead of [[LogLevels.Off]]
 2018-07-15 23:26:30 +09:00
Roman Niukhalov
24f79c3ca3
Merge branch 'master' into fix-receive-timeout 2018-07-14 02:16:42 +07:00
Roman Niukhalov
fc5aae354e Added exclude rules for binary compatibility check 2018-07-14 02:16:17 +07:00
Jason Longshore
c36598a93c Fix a typo in BroadcastHub doc (#25346) 2018-07-13 04:23:57 +01:00
Roman Niukhalov
929ce71372 Fixed scheduling and cancelling receive timeout #25340 
- The issue occurs when setReceiveTimeout is called during processing a message marked as NotInfluenceReceiveTimeout
 2018-07-13 01:22:27 +07:00
Patrik Nordwall
d330c61203
Merge pull request #25344 from akka/wip-25342-ReplicatorDeltaSpec-patriknw 
Harden ReplicatorDeltaSpec, #25342
 2018-07-12 12:25:14 +02:00
Patrik Nordwall
ebbdb6135e Harden ReplicatorDeltaSpec, #25342 
* It was a timing race condition in the test that was exposed
  by the change in PR #25315. Full state is now sent immediately
  when receiving the DeltaNack and that makes the Update complete
  much faster for that case than before.
* That resulted in that the delta propagations from previous
  updates were still in the buffer to be sent out when the
  incr(4) was performed. Those deltas contained the NoDeltaPlaceholder,
  which caused the inrc(4) delta to also be folded into NoDeltaPlaceholder
  and thereby not propagated.
* Before the DeltaNack the buffer had time to be flushed before the incr(4)
  and therefore no NoDeltaPlaceholder.
 2018-07-12 10:05:06 +02:00
Nathan Kleyn
a372ad8b03 Allow named pipes / FIFOs when using FileIO #25328 2018-07-12 08:31:16 +02:00
Patrik Nordwall
d76b27ba3e
Optimize flatMapConcat for single element source, #25241 (#25242) 
* Optimize flatMapConcat for single element source, #25241

* Grab the SourceSingle via TraversalBuilder

* Also handle the case when there is no demand

* don't match when mapMaterializedValue and async
 2018-07-11 18:19:40 +02:00
Arnout Engelen
97490eb30c Fix publishing akka-stream_2.12 with jdk8 and jdk9 classes (#25341) 
* Fix publishing akka-stream_2.12 with jdk8 and jdk9 classes

* Only build jdk9 classes on jdk9+

* Avoid -release on jdk8
 2018-07-11 15:37:47 +02:00
Benny ill
1ba9123315
Merge branch 'master' into master 2018-07-11 13:32:00 +02:00
Patrik Nordwall
231672fc1c
Merge pull request #25308 from DataDome/akka_remote_shutdown_warning 
Changed log-level of ShutDownAssociation from Error to Warning
 2018-07-11 13:30:39 +02:00
Patrik Nordwall
180ef934bc Improve performance of DData delta updates, #25310 
* Use deterministic order of the target nodes for the writes when
  type RequiresCausalDeliveryOfDeltas, otherwise the random pick
  of targets caused that delta sequence numbers were missing for
  susequent updates
* Resend immediately when receiving DeltaNack instead of waiting
  for timeout. DeltaNack can happen when there are multiple
  concurrent updates from same node because each starts a WriteAggregator
  and a later Update might bypass an earlier
 2018-07-11 13:14:25 +02:00
Arnout Engelen
db48514b88 Reintroduce CallerSensitive (#25326) 
Not having it causes a compile error in 'sbt ++2.12.6 clean akka-actor/compile'
on jdk9, though I can't quite explain why: using the jdk8 classpath otherwise
seems to work, and I can't reproduce it in a minimal example yet.

This reverts commit c6735b630b75408b0c8bbdb22dd31f7d144346ef.
 2018-07-11 11:50:45 +01:00
Patrik Nordwall
46e9c29d00
Merge pull request #25334 from akka/wip-25156-supervision-and-stopped-johanandren 
Typed supervision did not handle stopped behaviors correctly #25156
 2018-07-11 12:14:59 +02:00