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

116 commits

Author SHA1 Message Date
Mathias
7498533509 =docs #17600 fix incorrect http client example 2015-06-19 14:39:00 +02:00
Alek Storm
d3742c577a +htp extract multiple occurrences in the parameters/formFields directives by suffixing with .* 2015-06-17 22:21:37 -07:00
drewhk
16afc46931 Merge pull request #17446 from drewhk/wip-17310-basic-framing-support-drewhk 
+str #17310: Basic framing support
 2015-06-12 10:40:01 +02:00
Viktor Klang
3dd40fc18c +str - #17662 - Changes Sink.ignore to return a Future[Unit] 2015-06-05 21:30:36 +02:00
Endre Sándor Varga
6318f3e972 +str #17310: Basic framing support 2015-06-02 14:24:42 +02:00
drewhk
0e6694a102 Merge pull request #17633 from 2m/wip-buffer-drop-new 
dropNew overflow strategy
 2015-06-02 12:22:58 +02:00
Martynas Mickevičius
e863a9c703 =str #17167 drop new overflow strategy 2015-06-01 18:08:13 +03:00
drewhk
c59a176a84 Merge pull request #17506 from spray/w/16826-introduce-cookie-pairs 
!htc #16826 introduce HttpCookiePair for usage in `Cookie`-header
 2015-06-01 16:12:56 +02:00
drewhk
67f8e1b79d Merge pull request #17544 from drewhk/wip-minor-stream-cleanups 
=str: Don't use "remaining", check proper localized TCP messages
 2015-05-29 14:19:09 +02:00
drewhk
e2eab532ab Merge pull request #17552 from spray/w/fix-implicits 
=htp add explicit result types to formField/parameter implicits
 2015-05-28 12:51:13 +02:00
Johannes Rudolph
b2e6b650fd !htc #16826 introduce HttpCookiePair for usage in Cookie-header 2015-05-28 12:43:45 +02:00
Johannes Rudolph
c417d727da =htp add explicit result types to formField/parameter implicits 
Otherwise, the applicability of the implicit conversions can depend on
the order of compiler-internal loading/typing which is hardly predictable.
 2015-05-22 14:37:21 +02:00
Johannes Rudolph
4b256f7c1a =doc another batch of documentation (example) fixes 2015-05-21 17:34:46 +02:00
Endre Sándor Varga
2a2f2f075e =str: Don't use "remaining", check proper localized TCP messages 2015-05-21 16:03:10 +02:00
Johannes Rudolph
fd85cac20f =doc fix mentions of spray and link to magnet pattern 2015-05-21 13:24:57 +02:00
Johannes Rudolph
546936146b =doc fixed example compile errors either by fixing files or commenting them for now 2015-05-21 10:53:37 +02:00
Mathias
20759e1b34 =doc Significantly extend HTTP documentation with new content and ports from spray docs 2015-05-21 10:53:24 +02:00
Konrad Malawski
60f0bfba5d =str IO stream sink/source materialized value must be boxed explicitly 2015-05-19 12:19:09 +02:00
Endre Sándor Varga
7ad4fdc3ce !str #17123: Make materialized value handling method names consistent 2015-05-05 12:42:41 +02:00
Roland Kuhn
55e1d71eea !str #17327 use curried methods for mapAsync 2015-04-28 17:40:45 +02:00
Mathias
4537fdebf5 =doc #17279 upgrade to new http package layout 2015-04-24 18:44:25 +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
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
Martynas Mickevičius
8e2cc3e70f =str #17089 stream testkit 2015-04-24 12:25:54 +03:00
Endre Sándor Varga
6736d91110 +doc, str #16714: Add documentation explaining parallelism and pipelining 2015-04-24 10:30:15 +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
Roland Kuhn
616838a738 +str #15833 TLS with session renegotiation 2015-04-23 15:53:52 +02:00
Patrik Nordwall
00033313e0 !str #16951 Unify scaladsl and javadsl OperationAttributes 
* Move actor specific attributes to ActorOperationAttributes
 2015-04-16 14:16:01 +02:00
Patrik Nordwall
b69988c190 !str #16937 Remove section, in favor of via and separate flow 2015-04-10 17:34:29 +02:00
Mathias
d92fcf211a =doc #17039 change default materialization placeholder type from Unit to Any 2015-04-10 15:10:42 +02:00
Patrik Nordwall
f4ed62b84c !str #16520 Add ActorRefSource 
* and rename the factory for ActorPublisherSource,
  from Source.apply to Source.actorPublisher

* including internal buffer, with OverflowStrategy

* support to complete/fail stream
 2015-04-10 13:53:15 +02:00
Patrik Nordwall
946faedd95 !str #16521 Add ActorRefSink 
* also rename the factory for ActorSubscriber props Sink,
  from apply to actorSubscriber
 2015-04-10 12:58:52 +02:00
Roland Kuhn
8f47b6dfcc Merge pull request #17105 from akka/wip-async-stage-∂π 
add async stage
 2015-04-10 10:52:01 +02:00
Roland Kuhn
4c623fade7 !str #17090 add AsyncStage 2015-04-10 09:00:36 +02:00
Patrik Nordwall
514adc1150 =str #16913 enable and fix broken StreamTcpDocSpec 2015-04-10 07:44:43 +02:00
drewhk
a65adc5f16 Merge pull request #17097 from drewhk/wip-16168-mat-value-source-drewhk 
!str #16168: Expose materialized value in the graph as a "source"
 2015-04-07 13:28:32 +02:00
Endre Sándor Varga
a7af773e2c !str #16168: Expose materialized value in the graph as a "source" 2015-04-07 12:51:18 +02:00
Martynas Mickevičius
03a1a8ea3d Merge pull request #17072 from 2m/wip-enable-java8-tests 
Enable java-lambda doc sample build in PR validation
 2015-03-31 13:56:00 +03:00
Jun
a9a7a799fc =doc fix typo: form -> from 
Ports #17074 to the right branch
 2015-03-30 10:02:50 +02:00
Martynas Mickevičius
1933b77510 =doc #16989 update http bind documentation 2015-03-26 21:38:27 +02:00
Martynas Mickevičius
7616b40e29 =sam #16905 multiple fixes for java-lambda doc samples 
* use a free port instead of a hardcoded one
* do not use null for stream elements
* use defined java8 home key
 2015-03-26 20:56:49 +02:00
Roland Kuhn
157629f8af !str #16416,#16994 BidiFlow DSL and Flow.join Mat 
- add BidiFlow, with atop and join combinators
- add Flow.join(BidiFlow)
- correct Flow.join’s default materialized value selection to Keep.left
 2015-03-24 11:10:14 +01:00
Patrik Nordwall
9ae08a57fe Merge pull request #17018 from danielwegener/patch-1 
=doc: Simplyfies decider in FlowErrorDocSpec.scala
 2015-03-06 16:07:29 +01:00
Daniel Wegener
c6b51ea555 Doc: Simplyfies decider in FlowErrorDocSpec.scala 
Or is there any reason to do an explicit match?
 2015-03-06 12:15:20 +01:00
Patrik Nordwall
3dc4e6d077 !str #16992 Rework Source and Sink name parameter 
* Remove name parameter (no overloads), naming is performed using `.withAttributes` or the new
  convenience `.named`. Those adds the OperationAttribute.Name and also change the name of the
  shape Inlet and Outlet.

* Remove Source/Sink parameter list for 0 parameter methods,
  this allows usage of `Sink.head` instead of `Sink.head()`
 2015-03-06 09:24:00 +01:00
Roland Kuhn
91a0dbe036 Graph#Shape needs uncheckedVariance in 2.11 2015-02-27 20:32:15 +01:00
Roland Kuhn
70c6c1a246 Merge pull request #16949 from spray/wip-16835-mathias 
Refactor akka.http.server.RejectionHandler
 2015-02-27 14:11:52 +01:00