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

1686 commits

This branch
This branch
All branches
Author SHA1 Message Date
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
Martynas Mickevičius
eb4cb47762 Merge pull request #17241 from 2m/wip-graphbalancespec-robustify 
=str #17176 do not check for arbitrary conditions that depends on thread scheduling
 2015-04-24 15:30:43 +03:00
Patrik Nordwall
1595a8a911 !str #17031 Rename StreamTcp to Tcp 2015-04-24 14:13:54 +02:00
Patrik Nordwall
07f299a1e0 !str #17031 Use host and port instead of InetSocketAddress 
* as convenience in bind and outgoingConnection
 2015-04-24 14:12:43 +02:00
drewhk
a44f8b42e2 Merge pull request #17296 from drewhk/wip-17254-use-shapes-when-possible-drewhk 
+str #17254: Accept graphs instead of Flow/Source/Sink etc.
 2015-04-24 14:05:12 +02:00
Endre Sándor Varga
d73f78dcbf +str #17254: Accept graphs instead of Flow/Source/Sink etc. 2015-04-24 13:14:00 +02:00
Konrad Malawski
f5cafd0342 Merge pull request #17293 from ktoso/wip-improve-dispatcher-checking-ktoso 
=str more robust dispatcher checking in FileSource specs
 2015-04-24 13:06:33 +02:00
Martynas Mickevičius
b1431313e5 =str #17176 do not check for arbitrary conditions that depends on thread scheduling 2015-04-24 13:32:16 +03:00
Konrad Malawski
0aecf21c7a =str more robust dispatcher checking in FileSource specs 2015-04-24 12:27:48 +02:00
Roland Kuhn
1a5d114290 Merge pull request #17294 from 2m/wip-tlsspec-testkit 
=str fix compilation issue after #17238 merge
 2015-04-24 12:09:25 +02:00
Martynas Mickevičius
85bd6fa618 =str fix compilation issue after #17238 merge 2015-04-24 13:06:58 +03:00
drewhk
e550740390 Merge pull request #17164 from drewhk/wip-16716-stage-semantics-documentation-drewhk 
+doc, str #16716: Table summarizing built-in processing stages
 2015-04-24 11:58:13 +02:00
Roland Kuhn
874bb12128 Merge pull request #17285 from akka/wip-17277-akka.japi.function-∂π 
!str #17277 remove akka.stream.javadsl.japi.WithVariance
 2015-04-24 11:50:10 +02:00
Roland Kuhn
995e659310 Merge pull request #17287 from spray/w/17129-provide-error 
Improve error message if serverLayer is reused.
 2015-04-24 11:44:11 +02:00
Endre Sándor Varga
e82b89e285 +doc, str #16716: Table summarizing built-in processing stages 2015-04-24 11:29:23 +02:00
Martynas Mickevičius
e15891b7c9 Merge pull request #17238 from 2m/wip-stream-testkit 
=str #17089 stream testkit
 2015-04-24 12:26:43 +03:00
Martynas Mickevičius
8e2cc3e70f =str #17089 stream testkit 2015-04-24 12:25:54 +03:00
Roland Kuhn
7b4a640147 Merge pull request #17289 from akka/wip-SslTls-termination-∂π 
refactor SslTlsActor and stop it reliably
 2015-04-24 11:22:28 +02:00
drewhk
8694f48126 Merge pull request #17161 from drewhk/wip-16714-doc-stream-parallelism-drewhk 
+doc, str #16714: Add documentation explaining parallelism and pipelining
 2015-04-24 11:21:32 +02:00
Roland Kuhn
354a8e3a41 !str #17277 remove akka.stream.javadsl.japi.WithVariance 
sadly we forgot to also move the boilerplate-generated FunctionN and
ProcedureN into akka-actor, so they are still in
akka.stream.javadsl.japi.
 2015-04-24 11:05:11 +02:00
Johannes Rudolph
70a147a581 =htc #16887 properly report truncated WS messages to user handler 2015-04-24 10:55:24 +02:00
Roland Kuhn
3626f3ee0d Merge pull request #17266 from spray/w/http-server-java-api 
+htc resurrect low-level server-side Java API and JavaTestServer
 2015-04-24 10:54:20 +02:00
Johannes Rudolph
5e459688d5 =htc #17129 improve error message that serverLayer cannot be reused 2015-04-24 10:53:54 +02:00
Johannes Rudolph
48b50b6a84 =htc #16887 remove duplication in TestServer 2015-04-24 10:53:54 +02:00
Johannes Rudolph
50f488f563 +htc resurrect low-level server-side Java API and JavaTestServer 
Modelled after javadsl.StreamTcp.
 2015-04-24 10:52:54 +02:00
Roland Kuhn
4132e026ec refactor SslTlsActor and stop it reliably 
- this also discovered two omissions in the Transfer infrastructure:

  - inputsAvailableFor should be completed when the input is cancelled
  - demandAvailableFor should be completed when the output is errored

also switch off tracing for SslTls—we don’t want this on in production
 2015-04-24 10:40:21 +02:00
Endre Sándor Varga
6736d91110 +doc, str #16714: Add documentation explaining parallelism and pipelining 2015-04-24 10:30:15 +02:00
Roland Kuhn
0ac7900e9e Merge pull request #17282 from spray/w/17278-change-to-javadsl-in-java-model 
!htc #17278 replace remaining usages of scaladsl.Source in akka.http.model.japi
 2015-04-24 10:20:14 +02:00
Roland Kuhn
1ccaf572d5 Merge pull request #17283 from spray/wip-16507-mathias 
log materialization errors in `bindAndHandle`
 2015-04-24 10:16:51 +02:00
Konrad Malawski
089760e4e5 Merge pull request #17273 from ktoso/wip-stream-io-implicits-ktoso 
+str #15588 Additional way of using IO sink/source
 2015-04-23 23:00:28 +02:00
Mathias
6ce8e0f29d =htc #16507 log materialization errors in bindAndHandle 2015-04-23 22:40:01 +02:00
Mathias
15b95ab0e5 =str fix typo in internal type (RejectAdditionalSubscribers) 2015-04-23 22:37:34 +02:00
Konrad Malawski
337850919e +str #17284 allows deciding to stop after signaling terminal or not 2015-04-23 21:42:18 +02:00
Patrik Nordwall
ae430f0521 Merge pull request #17217 from akka/wip-16986-cancelation-leak-patriknw 
=str #16986 Handle early cancelation issue
 2015-04-23 20:52:15 +02:00
Konrad Malawski
311c94f53a +str #15588 Additional way of using IO sink/source 
> Similarily to akka.stream.extra._
 2015-04-23 20:36:40 +02:00
Patrik Nordwall
f4703d8916 =str #16986 Handle early cancelation issue 
* if downstream cancels before subscription from upstream is
  received the cancel was not propagated to upstream, the
  actor was stopped too early
 2015-04-23 20:00:13 +02:00
Patrik Nordwall
f930bcdda8 =str #15191 Verify that stage actors are stopped 
* found one bug of too early actor stop and thereby missing cancel of upstream,
  in fan-in tests ""work with one immediately failed and one nonempty publisher"
 2015-04-23 20:00:12 +02:00
drewhk
2152340ba8 Merge pull request #17280 from drewhk/wip-16940-shallow-layout-copy-drewhk 
=str #16940: Implement shallow copy for stream layouts
 2015-04-23 19:37:04 +02:00