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

116 commits

Author SHA1 Message Date
Patrik Nordwall
98a51e331c
Merge pull request #25353 from chbatey/issue-24956-streamtestkitspec 
Harden StreamTestKitSpec
 2018-08-23 11:34:04 +02:00
Kazuhiro Sera
482eaea122 Fix several minor typos detected by github.com/client9/misspell (#25448) 
* Fix several minor typos detected by github.com/client9/misspell

* Revert s/erminater/erminator/ in /ActorSystemSpec
 2018-08-21 11:02:37 +09:00
Christopher Batey
503811f634 Harden StreamTestKitSpec 
Closes #24956
 2018-07-16 06:21:54 +01:00
Martynas Mickevičius
766944a592
Expose assertAllStagesStopped 2018-06-27 10:34:32 +03: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
Richard S. Imaoka
60eee84345 Replace graph with operator in Scaladoc/Javadoc 2018-06-09 17:42:56 +09:00
Christopher Batey
59ed3b353f Harden StreamTestKitSpec #24956 2018-04-24 12:24:53 +01:00
Patrik Nordwall
c67a86ac99
Merge pull request #24743 from delftswa2018/remove-stream-testkit-coroner 
Remove the duplicated class Coroner.scala
 2018-03-16 17:36:50 +01:00
Martijn Steenbergen
39d21ade99 Remove the duplicated class Coroner.scala 2018-03-16 15:42:04 +01:00
Jimin Hsieh
2c2b8ba001 Remove some of Unused import warning (#24650) 2018-03-16 12:08:29 +01:00
Konrad `ktoso` Malawski
563c7fbcf0 Issue 24594: Integration with sbt-headers and initial header population 2018-03-13 15:45:55 +01:00
kerr
97ca714d17 = all remove semicolons "bye-bye semicolon" (#24659) 2018-03-06 09:53:28 +09:00
Patrik Nordwall
5fdb247488 harden StreamTestKitSpec, #24308 2018-01-16 18:30:33 +01:00
Christopher Batey
009214ae07
Update copyright to 2018 (#24241) 2018-01-04 17:26:29 +00:00
Johannes Rudolph
9d7621150f =stk accept Throwable in stream probe's sendError methods (#23940) 2017-11-09 09:12:58 +01:00
Patrik Nordwall
f017f6a90a Optimize TCP stream writes, #23919 (#23920) 
* This is an optimization of TcpStreamLogic to accumulating bytes in a buffer while waiting for
  acknoledgment of pending write. This improves throughput for small messages (frames)
  without sacrificing latency. While waiting for the ack the stage will eagerly pull
  from upstream until the buffer limit is exceeded. Accumulated bytes are written
  immediately when ack is received.
* Noticed 20x throughput improvement with Artery MaxThroughputSpec thanks to this buffer
  when working on the Artery TCP implementation. The small message (100 bytes) benchmark
  improved from 30k msg/s to 600k msg/s.
 2017-11-07 11:07:29 +09:00
Arnout Engelen
b8a18bcf30 Nicer message when expectCancellation() fails (#23847) 2017-10-25 09:14:21 +09:00
Patrik Nordwall
a10b00ed02 harden RestartSpec, less timing sensitive, #23593 (#23731) 2017-09-26 21:46:52 +09:00
Kirill Yankov
dfd94d3aea New implementation of expectNoMsg in TestKit #23224 2017-09-25 16:37:47 +02:00
Alexander Golubev
1ba5b27158 =str add latch to ManualProbe to popagate events only when subscription is done (#23365) 2017-08-21 11:26:29 +02:00
Martynas Mickevičius
bc0f2ee26d Load MiMa filters from file (#23083) 2017-07-27 12:33:14 +02:00
Martynas Mickevičius
e63054173d #22889 Use port 0 for address which is supposed to never be bound 2017-06-04 11:45:08 +02:00
Hawstein
6434cbe868 Re-implement javadsl testkit (#22240) 
* re-implement javadsl testkit

* fix mima problem

* rebase master

* move ImplicitSender/DefaultTimeout to scaladsl

* undo the change of moving scala api

* fix return type and add doc

* resolve conflicts and add more comments
 2017-03-16 20:02:47 +01:00
Endre Sándor Varga
ba63c7af8d New materializer and layout 2017-03-01 16:18:55 +01:00
Kirill Yankov
cf73ffd16a expectNextPF with timeout #21314 (#21825) 
* expectNextPF with timeout #21314

improved scaladocs

* renamed functions with timeout, returned previous comments for the sake of unification
 2017-02-23 13:46:00 +01:00
Philippus Baalman
6c7085252a extended copyright into 2017 2017-01-04 17:37:15 +01:00
Johan "Party Cannon" Andrén
80daa2f647 Race condition fix for Test{Sink/Source}Stage #20737 2016-12-08 13:18:29 +01:00
Johannes Rudolph
a31e78b47f +stk expose within for both TestSubscriber and TestPublisher 
This will allow us place limits on methods like `expectRequest` without
introducing other overloads.
 2016-11-17 12:23:14 +01:00
Kirill Yankov
7eb660b497 Add expectNextChainingPF method to streams testkit #21614 (#21617) 
Add expectNextChainingPF method to streams testkit #21614

Improved error messages on expectNextPf, expectNextPfChaining, expectEventPF
 2016-10-17 18:08:09 +03:00
Alexander Golubev
e0d73187bd =str 20967 print stream state on test failed (#21003) 2016-07-22 10:03:26 +02:00
Andrea Peruffo
a230f2fe34 =str switch to java std lib ThreadLocalRandom. (#20877) 2016-07-05 14:59:48 +02:00
Endre Sándor Varga
e54d2933bd #19931 Track pending requests properly on expectRequest 2016-06-27 12:56:29 +02:00
Hawstein
6777e7f7d9 +doc #20466 example snippet for akka http java dsl: ParameterDirectives (#20823) 2016-06-23 23:29:01 +02:00
kbrowder
d6eebd22ef +htt #20815 Add expectNext(d: FiniteDuration) and requestNext(d: FiniteDuration) (#20819) 
* Add expectNext(d: FiniteDuration) and requestNext(d: FiniteDuration) for issue 20815

* add some comments on requestNext
 2016-06-22 21:27:09 +02:00
Björn Antonsson
c66ce62d63 Update to a working version of Scalariform 2016-06-02 22:12:36 +02:00
2beaucoup
bc7cd17bee =htc Various minor cleanups (#20451) 
* minor fixes

* remove now superfluous buffer from MultipartUnmarshaller

* remove unused TokenSourceActor

* remove FIXME: add tests, see #16437

* removed unused param remoteAddress (comment: TODO: remove after #16168 is cleared)

* convert FIXME to TODO (#18709)

* reenable tests in {Request|Response}RendererSpec due to fixed #15981

* remove logging workaround in StreamTestDefaultMailbox due to fixed #15947
 2016-05-06 10:32:06 +02:00
Wojciech Langiewicz
2cdf447f6e =doc fix scaladoc warnings #18500 2016-03-16 09:18:39 +01:00
Roland Kuhn
45e97e8467 remove akka.stream.testkit.AkkaSpec, fixes #19879 2016-02-25 15:26:51 +01:00
Johannes Rudolph
b6cbc7f13a =all remove unused imports 2016-02-23 20:29:22 +01:00
Johan Andrén
62e30b3c08 Update copyrights and links to the new company name #19851 2016-02-23 12:58:39 +01:00
Alexander Golubev
a10bba9c84 =str #19291 add TestGraphStages for Sink and Source 2016-01-26 11:47:30 -05:00
Prayag Verma
b7783968a0 =pro #19068 All copyrights ranges and single years updated to a range ending in 2016 2016-01-25 10:20:30 +01:00
Roland Kuhn
e5baba2b29 squash some warnings 2016-01-20 11:54:24 +01:00
Endre Sándor Varga
60497f6561 also fix FlowInterleaveSpec 
Also-by: Johan Andrén <johan@markatta.com>
Also-by: Roland Kuhn <rk@rkuhn.info>
Also-by: Martynas Mickevičius <mmartynas@gmail.com>
 2016-01-20 10:01:58 +02:00
Roland Kuhn
960cc5a6e4 fix up StreamTestKitSpec 2016-01-16 17:55:03 +01:00
2beaucoup
f7a5151bbb #19447 remove compatibility fallbacks for Java < 8 2016-01-14 15:52:13 +01:00
Roland Kuhn
6fa6e39c22 #19326 do not call TestKit.remaining for Akka 2.4 compatibility 2016-01-13 16:39:52 +01:00
Konrad Malawski
86504ec4e2 =str #19377 improve expectNext() error reporting (if no element signaled) 2016-01-13 16:39:46 +01:00
Konrad Malawski
59a079d1f2 Merge pull request #19219 from ktoso/wip-sslconfig-ktoso 
Apply ssl-config and include hostname validation
 2015-12-21 14:41:40 +01:00
Konrad Malawski
8cf86e693c =htp #19184 better TLS defaults and hostname verification 
+ depends on com.typesafe.ssl-config which we'll need to release
+ also makes tests compile on JDK6, to enable testing this on JDK6
 2015-12-21 13:20:24 +01:00