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

1661 commits

This branch
This branch
All branches
Author SHA1 Message Date
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
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
Konrad Malawski
ce72ca3363 Merge pull request #17211 from ktoso/wip-filesource-java6-ktoso 
+str #15588 Java 6 Synchronous File Sink / Source
 2015-04-23 19:09:38 +02:00
Konrad Malawski
cebd9bf1ae +str #15588,#17229 Java 6 Synchronous File Sink / Source 
These are synchronous implementations, because we need to be Java 6
  compatible while developing on 2.3.x. However asynchronous
  implementations using AsynchronousFileChannel will come soon for JDK7
  users.

+ ActorPublisher/Subscriber now manage stopping of the actor
+ added documentation on configuring dispatcher for File IO
+ properly handle if source file does not exist
+ file sink / source come with default io dispatcher
> verified no actors are leaking
> exceptions are caught and onErrored properly
+ moved files to akka.stream.io
+ Added OutputStreamSink and InputStreamSource
 2015-04-23 18:15:10 +02:00
Endre Sándor Varga
82a7f13a02 =str 16940: Implement shallow copy of layouts 2015-04-23 18:00:01 +02:00
Roland Kuhn
a1639c4312 Merge pull request #17222 from spray/wip-15681-mathias-final 
Support for client-side HTTP connection pooling
 2015-04-23 17:59:05 +02:00
Roland Kuhn
2347744af3 Merge pull request #17231 from akka/wip-15833-tls-renegotiation-∂π 
+str #15833 TLS with session renegotiation
 2015-04-23 17:51:38 +02:00
Johannes Rudolph
d9adc3c711 =htc #16887 speed up some websocket tests 2015-04-23 17:20:31 +02:00
Johannes Rudolph
b86ce44961 !htc #17278 replace remaining usages of scaladsl.Source in akka.http.model.japi 2015-04-23 17:15:05 +02:00
Roland Kuhn
616838a738 +str #15833 TLS with session renegotiation 2015-04-23 15:53:52 +02:00
Mathias
21baac0c52 !htc #15681, #15906, #16852, #17064 add client-side connection pooling with retries 
Also: simplify API style for settings passing
 2015-04-23 15:31:52 +02:00
Mathias
4d3b0e4edc +htc, htp: small improvement to HttpMessage::withDefaultHeaders 2015-04-23 15:31:51 +02:00
Mathias
475c073997 =htc smaller improvements to util helpers 2015-04-23 15:31:48 +02:00
Mathias
5b0af36797 =str smaller improvements to ActorSubscriber 2015-04-23 15:12:53 +02:00
Mathias
fed89db739 =str widen Flow::andThenMat visibility from private[stream] to private[akka] 2015-04-23 15:12:53 +02:00
Mathias
53de0f3b74 +htc #17064 add Uri::toHttpRequestTargetOriginForm and double-slash path tests 
Forward port of https://github.com/spray/spray/pull/1026.
 2015-04-23 15:12:53 +02:00
Patrik Nordwall
33919f683c Merge pull request #17228 from akka/wip-16699-fixmes-patriknw 
=str #16699 fix some FIXMEs
 2015-04-23 14:37:20 +02:00
Patrik Nordwall
c63b9c801a =str #16699 fix some FIXMEs 2015-04-23 14:36:53 +02:00
Roland Kuhn
e7816b2979 Merge pull request #17248 from spray/w/websockets 
Server-side Websocket support
 2015-04-23 14:26:25 +02:00
Patrik Nordwall
f5472a5581 Merge pull request #17234 from akka/wip-15707-source-sink-names-patriknw 
=str 15707 Define default names for sources and sinks
 2015-04-23 13:23:29 +02:00
Patrik Nordwall
45da4513af Merge pull request #17243 from akka/wip-stream-supress-deadletters-patriknw 
=str Use some more DeadLetterSuppression
 2015-04-22 21:35:19 +02:00
Johannes Rudolph
6fef5d534c +htc #16887 add support for WS application-level subprotocol negotiation 2015-04-22 13:58:39 +02:00
Johannes Rudolph
cd87dadf54 +htp #16887 add simple websocket support directive to akka-http 2015-04-22 13:57:32 +02:00
Johannes Rudolph
23b9952149 =htc #16887 integrate websocket pipeline into http server 2015-04-22 13:57:32 +02:00
Johannes Rudolph
6dafa445de =htc #16887 implement high-level server-side Websocket API 2015-04-22 11:10:44 +02:00
Johannes Rudolph
880733eb3d =htc make headAndTail work if prefixAndTail returns an empty prefix 2015-04-22 11:10:44 +02:00
Johannes Rudolph
73722c425d =htc #16887 websocket framing implementation 2015-04-22 11:08:09 +02:00