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

1050 commits

This branch
This branch
All branches
Author SHA1 Message Date
Johannes Rudolph
bca5626fbd =htc improve error messages 2014-10-28 12:03:01 +01:00
Konrad Malawski
5562ceb94b Merge pull request #16116 from ktoso/wip-consistency-dsl-ktoso 
+str #16114 DSL consistency (factories)
 2014-10-27 11:46:03 +01:00
Konrad 'ktoso' Malawski
92810e39bc +str #16114 better consistency specs and missing methods added - javadsl 2014-10-27 11:44:42 +01:00
Martynas Mickevičius
1552ea7b0c Merge pull request #16133 from 2m/wip-persistent-source-16041 
=str #16041 Move PersistentSource to the latest Stream DSL
 2014-10-27 12:33:57 +02:00
Martynas Mickevičius
cdfd739778 Merge pull request #16119 from 2m/wip-actor-pub-sub-source-sink-16095 
=str #16095 make Actor{Publisher,Subscriber} as {Source,Sink}
 2014-10-27 12:33:16 +02:00
Martynas Mickevičius
3fbb6e6f87 =str #16041 Move PersistentSource to the latest Stream DSL 
* implemented as an extension of KeyedActorFlowSource
 2014-10-27 10:05:53 +02:00
Martynas Mickevičius
98523a847c =str #16095 make Actor{Publisher,Subscriber} as {Source,Sink} 
* Props{Source,Sink} creates an actor from props as a child
of StreamSupervisor actor and wraps it into {Publisher,Subscriber}.
Actor should be one of akka.stream.actor.Actor{Publisher,Subscriber}
 2014-10-27 09:48:54 +02:00
Patrik Nordwall
98452ef4c3 Merge pull request #16120 from akka/wip-16109-workaround-patriknw 
=str #16109 Workaround scalax.graph reflection issue
 2014-10-24 10:54:19 +02:00
Konrad Malawski
55c0074d33 Merge pull request #16110 from ktoso/wip-fan-ops-javadsl-ktoso 
+str #16077 implement Zip/Unzip/Concat for javadsl
 2014-10-23 17:55:09 +02:00
Konrad Malawski
1a7230ddb1 Merge pull request #16118 from ktoso/wip-error-overflowstrategy-ktoso 
+str #16046 implemented OverflowStrategy.error
 2014-10-23 15:00:13 +02:00
Konrad 'ktoso' Malawski
bb635a522c +str #16046 implemented OverflowStrategy.error 2014-10-23 14:58:39 +02:00
Konrad 'ktoso' Malawski
fd8a158d89 +str #16077 implement Zip/Unzip/Concat for javadsl, while reusing all impl 2014-10-23 10:50:27 +02:00
Patrik Nordwall
9b961bdb52 =str #16109 Workaround scalax.graph reflection issue 2014-10-22 16:52:50 +02:00
Martynas Mickevičius
a5ecb93d7a Merge pull request #16107 from ktoso/wip-cleanup-javadsl-ktoso 
=str #16103 Flattening FlowOps into Flow (same for Sink / Source)
 2014-10-22 12:12:06 +03:00
Konrad 'ktoso' Malawski
9dd3685a2a =str #16103 Flattened javadsl class structure - no adapters, no ops 2014-10-22 01:09:43 +02:00
Björn Antonsson
0261a6da48 Merge pull request #16111 from 2m/wip-unsingle-publisher-drain 
=str #16085 PublisherSink is no longer a singleton
 2014-10-21 17:28:44 +02:00
Björn Antonsson
789b7c843d Merge pull request #16108 from spray/w/port-more-directives 
Fixes for 15931, 15918, 15919
 2014-10-21 17:28:36 +02:00
Johannes Rudolph
689e7eb56a +htp add RequestContext/BasicDirectives.withLog/extractLog 2014-10-21 15:56:31 +02:00
Johannes Rudolph
cfcb88cf91 !htp rename conflicting withExecutionContext directive to extractExecutionContext 2014-10-21 15:56:31 +02:00
Johannes Rudolph
8116d2b9bb +htp #15919 import CookieDirectives 2014-10-21 15:56:31 +02:00
Johannes Rudolph
37da572d2d +htp #15918 import CacheConditions from spray 2014-10-21 15:56:30 +02:00
Benjamin Thuillier
c6f8eb95a1 +htp #15931 Import RespondWithDirectives from spray 2014-10-21 15:56:30 +02:00
Björn Antonsson
763dd640cd Merge pull request #16094 from spray/wip-15929-mathias 
Import ParameterDirectives from spray
 2014-10-21 15:41:16 +02:00
Mathias
0033e74cae !htp #16101 improve basic directive infrastructure, add more scaladoc, fix smaller problems 2014-10-21 14:12:01 +02:00
Mathias
9211b71c99 +htp #15929 port ParameterDirectives from spray 2014-10-21 14:12:01 +02:00
Mathias
33ddabbc9f =htp refactor tuple join to foldLeft-based implementation, unify tuple operations 2014-10-21 14:12:01 +02:00
Mathias
93c6a90e4e !htp #15935 clean up and extend unmarshalling infrastructure 2014-10-21 14:12:01 +02:00
Mathias
284a0fe61d =htp small improvement to Marshaller 2014-10-21 14:12:01 +02:00
Mathias
3fbe736960 =htp enable tests that were erroneously disabled due to specs2 -> scalatest copy-pasta 2014-10-21 14:12:01 +02:00
Mathias
129958d039 =htp add support infrastructure for folding over tuples with a binary poly-function 2014-10-21 14:12:00 +02:00
Mathias
416bb16aad =htc smaller improvements in FastFuture 2014-10-21 14:12:00 +02:00
Björn Antonsson
bca586a7dd Merge pull request #16091 from spray/w/15924-future-directives 
+htp #15924 import FutureDirectives from spray
 2014-10-21 13:42:49 +02:00
Johannes Rudolph
5870c4ab90 +htp #15924 import FutureDirectives from spray 2014-10-21 11:12:10 +02:00
Martynas Mickevičius
2df9c05d7c =str #16085 PublisherSink is no longer a singleton 
* rename existing Source/Sink tests to the latest names
* uncomment TickSource test with Zip
 2014-10-21 11:17:50 +03:00
Konrad Malawski
7053295de9 Merge pull request #16100 from spray/wip-16099-mathias 
=htc,htp #16099 remove all special treatment for ISO-8859-1, switch to U...
 2014-10-17 15:38:30 +02:00
Björn Antonsson
21b3410995 Merge pull request #16092 from akka/wip-remove-tap-and-drain-from-view-ban 
!str #16102 Fold Tap/Drain into Sink/Source
 2014-10-17 14:09:29 +02:00
Björn Antonsson
0f61909ea7 !str #16102 Fold Tap/Drain into Source/Sink 
* Fold Tap/Drain into Source/Sink
* Create Source/Sink helpers to create all Sources/Sinks
* Make concrete Source/Sink implementations private[scaladsl2]
 2014-10-17 14:05:50 +02:00
Mathias
ea7f3ff9fc =htc,htp #16099 remove all special treatment for ISO-8859-1, switch to UTF-8 as default charset everywhere 2014-10-16 14:14:23 +02:00
Konrad Malawski
41ca0522ef Merge pull request #16089 from spray/w/16088-fix-continuation-handling 
16087, 16088 fix RouteResult handling support in routing infrastructure
 2014-10-14 17:17:31 +02:00
Johannes Rudolph
4285f57bc3 !htp renaming: mapRouteResponse => mapRouteResult, mapHttpResponse => mapResponse 2014-10-14 12:23:13 +02:00
Johannes Rudolph
4d0e1ba231 !htp #16088 replace RouteResult.Failure by Future.failed + handle post-processing directly in Directives 
This replaces the awkward post-processing previously done with RequestContext.finish and
prevents the loop-hole of Future.failed which previously allowed errors
to be missed by the current ExceptionHandler.
 2014-10-14 12:23:13 +02:00
Johannes Rudolph
0e06406e19 !htp convert List[Rejection] => immutable.Seq[Rejection] everywhere 2014-10-13 18:03:46 +02:00
Johannes Rudolph
82a0fb381e +htc #16087 add FastFuture.transformWith and implement others in terms of that + recoverWith + lots of tests 2014-10-13 18:03:41 +02:00
Martynas Mickevičius
31642396a1 Merge pull request #16047 from ktoso/wip-java-streams-ktoso 
+str #15736 EARLY WIP akka-streams JavaAPIs
 2014-10-10 19:28:04 +03:00
Martynas Mickevičius
9d9296124a Merge pull request #16068 from spray/w/15921-import-encoding-directives 
15921, 16064, 16067 Import CodingDirectives + related fixes
 2014-10-10 19:06:57 +03:00
Konrad 'ktoso' Malawski
3a4c7404c7 +str #15736 Initial version of JavaDSL for akka-streams (NOT complete) 
Missing features are:
+ be able to use all junctions from Java
* re-think akka.stream.javadsl.japi (because variance)
+ better docs
+ enable all tests
+ Partial flow graph as well as GraphFlow tests
+ enabled more FlowTest tests
+ fixed naming of internal classes (no Java in class names)
+ added converters for UndefinedSink/Source
 2014-10-10 17:04:18 +02:00
Johannes Rudolph
2178e6a373 =htp #16063 fail on data truncation for GZIP coding 2014-10-10 16:52:15 +02:00
Johannes Rudolph
6170655b19 =htp #15921 import CodingDirectives from spray 2014-10-10 16:52:15 +02:00
Johannes Rudolph
8906a2fba8 =htc #16067 fix Chunked.transformDataBytes' onError/cleanup behavior 2014-10-10 16:40:50 +02:00
Johannes Rudolph
13fb925fe9 =htp #16064 fail properly and early if Gzip header is corrupt 2014-10-10 16:39:28 +02:00