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

22644 commits

This branch
This branch
All branches
Author SHA1 Message Date
Johan Andrén
4ddacb724d
Merge pull request #25380 from davimi/document-stream-source-range-operator 
Document stream source range operator #24933
 2018-07-30 16:11:04 +02:00
Johan Andrén
19124323bb
Merge pull request #25347 from nyukhalov/fix-receive-timeout 
Fixed scheduling and cancelling receive timeout #25340
 2018-07-30 16:09:45 +02:00
Johan Andrén
443f693c05
Merge branch 'master' into document-stream-source-range-operator 2018-07-30 14:32:41 +02:00
Johan Andrén
6d6bd16d41
Added missing lineefeed 2018-07-30 14:23:03 +02:00
Richard Imaoka
5ad00bed86
Merge branch 'master' into doc-23948-futures-pipeto-richard 2018-07-30 20:55:48 +09:00
Johan Andrén
ca08ca36e2
Turns out "-release 8" isn't enough with Scala 2.11.6 #25330 2018-07-30 13:44:11 +02:00
Christopher Batey
5835585993 Break up cluster sharding docs into sections 2018-07-30 09:31:12 +01:00
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