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

1723 commits

This branch
This branch
All branches
Author SHA1 Message Date
drewhk
050a930f4f Merge pull request #17439 from ktoso/wip-preStart-again-ktoso 
+str #17290 Adds preStart / postStop to AbstractStage
 2015-05-11 14:39:57 +02:00
Konrad Malawski
b0b6c9e98a preStart is now more type-safe, allows AsyncStage to provide it's Async context 2015-05-11 13:16:37 +02:00
Konrad Malawski
9607ec0cdf +str #17290 Adds preStart / postStop to AbstractStage 
+ AsyncStage now uses preStart
+ Log stage now uses preStart (better perf), can be optimised more
 2015-05-11 12:57:41 +02:00
drewhk
f24f43895d Merge pull request #17420 from spray/w/broken-gzip 
=htp #17417 in GzipDecoder don't pull if upstream has already finished
 2015-05-08 07:54:18 +02:00
drewhk
615323a5ec Merge pull request #17378 from drewhk/wip-17355-no-case-class-for-settings-drewhk 
!str #17355: Don't use case classes for settings
 2015-05-07 18:38:17 +02:00
drewhk
ad138e2b87 Merge pull request #17411 from drewhk/wip-17377-turn-off-validation-drewhk 
=str #17377: Turn off debug validation
 2015-05-07 18:16:37 +02:00
drewhk
27e37cd2fc Merge pull request #17410 from drewhk/wip-17407-mapAsync-resume-bug-drewhk 
=str #17407: MapAsync should pull when failed futures free up space
 2015-05-07 18:12:57 +02:00
drewhk
f9eb43ccd2 Merge pull request #17379 from drewhk/wip-17308-increase-sync-file-spec-timeout-drewhk 
=str #17308: Don't do blocking prefetch before subscription in fileSource
 2015-05-07 15:36:31 +02:00
Endre Sándor Varga
e0d078c676 !str #17355: Don't use case classes for settings 2015-05-07 15:33:35 +02:00
drewhk
8704e4a60b Merge pull request #17375 from drewhk/wip-17123-mat-method-name-consistency-drewhk 
!str #17123: Make materialized value handling method names consistent
 2015-05-07 15:25:17 +02:00
Endre Sándor Varga
605bbbce86 =str #17377: Turn off debug validation 2015-05-07 15:20:25 +02:00
Endre Sándor Varga
7f6a67a5c0 =str #17407: MapAsync should pull when failed futures free up space 2015-05-07 15:05:29 +02:00
Endre Sándor Varga
acc28f5820 =str #17308: Don't do blocking prefetch before subscription in fileSource 2015-05-05 13:55:00 +02:00
drewhk
9125a719fe Merge pull request #17373 from drewhk/wip-17351-fix-pushAndFinish-chain-drewhk 
=str #17351: Fix pushAndFinish improper stage termination
 2015-05-05 13:41:39 +02:00
Endre Sándor Varga
7ad4fdc3ce !str #17123: Make materialized value handling method names consistent 2015-05-05 12:42:41 +02:00
Martynas Mickevičius
d7f1c58251 Merge pull request #17330 from 2m/wip-no-fork-stream-tests 
=pro do not fork stream tests since #16544
 2015-05-05 13:31:52 +03:00
Endre Sándor Varga
6ba5c0b4c6 =str #17351: Fix pushAndFinish improper stage termination 2015-05-05 11:57:17 +02:00
Roland Kuhn
035037dd24 Utf8Decoder license clarified 
The license allows us to do everything that we need to do, provided that we keep it “with the Software”, which we understand to mean that this comment accompanying the affected code is sufficient. We have done this so far in all other cases as well.
 2015-04-30 13:54:31 +02:00
Konrad Malawski
2ba44464dc Merge pull request #17324 from ktoso/wip-17323-actorRefSource-better-completion-handling-ktoso 
=str #17323 Source.actorRef now emits buffered els before completion
 2015-04-30 13:13:18 +02:00
Konrad Malawski
e159e704e3 Merge pull request #17335 from spray/w/17322-fix-websocket-establishment-race 
#17322 Fix race condition during websocket connection establishment
 2015-04-30 13:07:59 +02:00
Konrad Malawski
c4204b1ba9 Merge pull request #17336 from spray/w/17334-fix-akka-parsing-dependency 
=pro #17334 mark scala-reflect and quasiquotes as provided dependencies
 2015-04-30 11:19:59 +02:00
Johannes Rudolph
23e8e25013 =pro #17334 mark scala-reflect and quasiquotes as provided dependencies 
Without moving `ruleType` out of the pattern matches compilation of
akka-http-core fails when scala-reflect isn't on the classpath in Scala 2.11.x.
 2015-04-29 16:44:43 +02:00
Johannes Rudolph
c283dd45ae =htc #17322 fix race condition between websocket http response and first websocket message 
The fix was to make the switch atomic instead of relying on side-channels
which introduced an ordering dependency in the protocol merge.

Also, the switch token itself is now fed back from the response renderer
output to the protocol switch leading to a simplified design.
 2015-04-29 13:03:57 +02:00
Johannes Rudolph
444a0deef5 =htc #16055 refactoring: make headAndTail a simple flow 2015-04-29 12:37:09 +02:00
Martynas Mickevičius
d01b53739c Merge pull request #17328 from akka/wip-17327-curried-mapAsync-∂π 
!str #17327 use curried methods for mapAsync
 2015-04-29 09:58:48 +02:00
Roland Kuhn
55e1d71eea !str #17327 use curried methods for mapAsync 2015-04-28 17:40:45 +02:00
Johannes Rudolph
0f15cb6d78 =htc extract HttpServerTestSetupBase from HttpServerSpec 2015-04-28 14:54:25 +02:00
Konrad Malawski
4ba11177ba =str #17323 Source.actorRef now emits buffered els before completion 2015-04-28 10:59:29 +02:00
Konrad Malawski
8714d556d5 Merge pull request #17313 from m-sp/fixTypoInStreamIO 
=doc fix typo in stream io
 2015-04-25 00:07:51 +02:00
Matthias Sperl
9cccb25499 =doc fix typo in stream io 2015-04-24 23:47:17 +02:00
Patrik Nordwall
26f975f4a4 Merge pull request #17311 from spray/w/add-core-client-side-java-api 
Http core client side Java API
 2015-04-24 19:50:17 +02:00
Martynas Mickevičius
2d2662eb81 Merge pull request #17306 from spray/wip-17279-mathias 
Refactor HTTP module and package structure
 2015-04-24 20:08:30 +03:00
Johannes Rudolph
df48e82e45 +htc client-side of http-core Java API 2015-04-24 18:53:05 +02:00
Johannes Rudolph
d25b3af252 !htc move ServerSettings and ParserSettings up a package to make them accessible both from the java and scala side 
This follow the example from akka.stream.
 2015-04-24 18:53:05 +02:00
Mathias
4537fdebf5 =doc #17279 upgrade to new http package layout 2015-04-24 18:44:25 +02:00
Mathias
d80f241f19 !ht* #17279 java side: refactor package structure to new layout 2015-04-24 18:44:25 +02:00
Mathias
10c8cf230e !ht* #17279 scala side: refactor package structure to new layout 2015-04-24 18:44:25 +02:00
Mathias
29063bce86 !htc #17279 refactor package structure to new layout 2015-04-24 18:44:24 +02:00
Mathias
5859c39f8b =ht* #17279 rename akka-http-* modules where agreed 2015-04-24 18:44:24 +02:00
Patrik Nordwall
20530be054 Merge pull request #17304 from akka/wip-minor-doc-patriknw 
=str minor doc syntax correction
 2015-04-24 17:37:35 +02:00
Patrik Nordwall
882975e546 =str minor doc syntax correction 2015-04-24 17:37:05 +02:00
Konrad Malawski
061c7572c2 Merge pull request #17307 from ktoso/wip-document-implicits-io-ktoso 
+doc documents how to use stream.io.Implicits
 2015-04-24 16:29:29 +02:00
Konrad Malawski
538f0fb884 +doc documents how to use stream.io.Implicits 2015-04-24 15:52:27 +02:00
Konrad Malawski
ed51c860e2 Merge pull request #17162 from ktoso/wip-logging-streams-ktoso 
Logging with log() stage for streams
 2015-04-24 15:39:57 +02:00
Konrad Malawski
f2b757df51 +str #17162 add log() stage for simple logging in Flows 
+ with javadsl
+ allows configuring log levels
+ allows turning off logging of certain actions completely
+ cookbook adjusted to show this instead of manual PushStage
- PENDING: preStart based impl will be faster, coming soon
 2015-04-24 15:37:39 +02:00
drewhk
a892ce1f0f Merge pull request #17300 from spray/w/add-websocket-java-api 
+htc #16887 the Java side of the Websocket server-side API
 2015-04-24 15:31:39 +02:00
Patrik Nordwall
676c8a17b8 Merge pull request #17297 from akka/wip-17031-tcp-http-symmetry-patriknw 
!str #17031 Change to host and port params, rename StreamTcp to Tcp
 2015-04-24 15:25:14 +02:00
Konrad Malawski
dea9c5a24a Merge pull request #17302 from akka/wip-move-boilerplate-functions-∂π 
move boilerplate FunctionN into akka.japi.function package
 2015-04-24 15:12:34 +02:00
Johannes Rudolph
3588a98a4b +htc #16887 the Java side of the Websocket server-side API 2015-04-24 14:40:27 +02:00
Roland Kuhn
5eb62f0a81 move boilerplate FunctionN into akka.japi.function package 
This is a temporary solution until the classes are added to akka-actor.
 2015-04-24 14:35:41 +02:00