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

960 commits

This branch
This branch
All branches
Author SHA1 Message Date
Konrad 'ktoso' Malawski
ec3cecb896 =pro #15178 enable junit tests in akka-streams again 
The junit-interface is treating "anything it cannot understand" as a
globbing pattern, thus when it didn't understand ScalaTest options, it
used them for globbing, and of course none of our junit tests matched
the "-oDF" pattern for example.

Debugged this with Stefan and we've opened an issue to improve the
integration in this respect:
https://github.com/sbt/junit-interface/issues/60

Resolves #15178
 2014-10-08 15:31:51 +02:00
Patrik Nordwall
afd45a09f4 Merge pull request #16034 from akka/wip-15950-runWithSink-patriknw 
!str #15950 Add runWith and remove toX
 2014-10-06 16:15:21 +02:00
Patrik Nordwall
18868842d3 +str #15950 Add fold and foreach shortcuts 2014-10-06 14:46:52 +02:00
Patrik Nordwall
14d3501f92 !str #15950 Add runWith and remove toX 
* runWith(drainWithKey) and runWith(tapWithKey) returning the
  materialized drain/tap
* remove toPublisher, toSubscriber, and friends, in favor of using
  runWith
* MaterializedMap is the return type for both flow and graph
* Source[T] return type for Source.apply methods
 2014-10-06 12:12:05 +02:00
Patrik Nordwall
dc4d121f48 Merge pull request #16016 from akka/wip-15905-interconnect-flow-graphs-patriknw 
+str #15905 Add capability to merge and connect flow graphs
 2014-10-06 11:40:47 +02:00
Patrik Nordwall
21df1984d2 Merge pull request #16032 from akka/wip-16028-clean-up-duplication-of-tap-source-flow-ops-ban 
=str #16028 Cleaned up ducplicate implementations of FlowOps
 2014-10-06 11:34:01 +02:00
Patrik Nordwall
989995e118 +str #15905 Add capability to merge and connect flow graphs 
* import edges of another flow graph to the builder
* connect undefined sink with undefined source, which may originate
  from different flow graphs
* illustrate how this low level api can be used in a high level api
  (lego bricks)
 2014-10-03 15:18:10 +02:00
Martynas Mickevičius
ba40bfa399 Merge pull request #16013 from 2m/wip-hook-balance 
=str #15874 Hook-up balance operation
 2014-10-03 15:57:12 +03:00
Björn Antonsson
52f7847de6 =str #16028 Cleaned up ducplicate implementations of FlowOps 2014-10-03 14:22:14 +02:00
Patrik Nordwall
b2e7804512 Merge pull request #16010 from akka/wip-15946-simple-flow-graphs-patriknw 
+str #15946 Support flows without junctions in FlowGraph
 2014-10-03 14:09:33 +02:00
Patrik Nordwall
f836339996 +str #15946 Support flows without junctions in FlowGraph 
* run simple flow with source/sink without any junctions in FlowGraph
* partial flow graph with undefined source/sink and flows, without junctions
* replace undefined source/sink with flow with source/sink
 2014-10-03 14:08:55 +02:00
Björn Antonsson
2f6499bcdf Merge pull request #16015 from spray/wip-16014-mathias 
=htc Fix handling of non-BMP characters in URI encoding/decoding
 2014-10-03 11:13:09 +02:00
Björn Antonsson
be581dffc1 Merge pull request #15984 from spray/w/15910-encoding-infrastructure 
+htp #15910 import coding infrastructure from spray
 2014-10-03 11:13:06 +02:00
drewhk
b237f78b3b Merge pull request #16023 from drewhk/wip-15888-fix-unguarded-queue-access-ssl-drewhk 
=str #15888: Fix unguarded access to input queue causing NPE
 2014-10-03 10:57:49 +02:00
drewhk
fbdd0dc5de Merge pull request #16025 from drewhk/wip-http-bind-failure-testcase-drewhk 
=htc Add test case for bind failures
 2014-10-03 10:18:30 +02:00
Martynas Mickevičius
3454fea029 =str #15874 Hook-up balance operation 2014-10-03 09:00:08 +03:00
Björn Antonsson
a8013f20b2 Merge pull request #16007 from akka/wip-15977-changin-all-the-small-dsl-things-ban 
+str #15977 Rename and change types in the new DSL
 2014-10-03 07:52:23 +02:00
Konrad Malawski
57c12ccc77 Merge pull request #16024 from ktoso/wip-hco-java-api-connection-ktoso 
+hco #15798 add missing java api for Connection.tokens
 2014-10-02 22:41:34 +02:00
Konrad 'ktoso' Malawski
e8f803d011 +hco #15798 add missing java api for Connection.tokens 
Resolves #15798
 2014-10-02 18:47:33 +02:00
Björn Antonsson
a6ab82f992 !str #15977 Rename and change types in the new DSL 
* Cleaned up type signatures
* Changed names of Source/Sink/ProcessorFlow to Tap/Drain/Pipe
* Introduced new Source/Sink/Flow
* Made all Pipe types package private
* Changed the TypeGraph DSL to work on Flow/Sink/Source
 2014-10-02 17:32:08 +02:00
Endre Sándor Varga
7dab9636e4 =htc Add test case for bind failures 2014-10-02 17:02:57 +02:00
Endre Sándor Varga
dbb6dbe65b =str #15888: Fix unguarded access to input queue causing NPE 2014-10-02 15:24:48 +02:00
Johannes Rudolph
fb98d1aa69 +htp #15910 import + improve coding infrastructure from spray 2014-10-02 15:22:06 +02:00
Björn Antonsson
afa1a6fd44 Merge pull request #16006 from volkerstampa/wip-16001-foldsink-error-handling-volkerstampa 
Propagate error to FoldSink's future. Fixes #16001
 2014-10-02 09:27:14 +02:00
Volker Stampa
a4efb121e0 =str #16001 Propagate error to FoldSink's future 
* align OnCompleteSink's implementation of error/success handling with
  that of other Sink's
 2014-10-01 21:34:12 +02:00
Mathias
abf4091bb7 =htc Fix handling of non-BMP characters in URI encoding/decoding, closes #16014 
Also improved the tests for this as they were sub-par so far
 2014-10-01 17:16:16 +02:00
Patrik Nordwall
f869979835 Merge pull request #16008 from akka/wip-15960-variance-take2-patriknw 
=str #15960 Fix broken FlowGraphCompileSpec
 2014-10-01 15:01:34 +02:00
Patrik Nordwall
08a0014fe7 =str #15960 Fix broken FlowGraphCompileSpec 
* FlowGraphCompileSpec broke when merging in the unzip on top of
  the variance adjustements
* JunctionOutPort[T] must not be defined like JunctionOutPort[+T]
  because then the NextT = Nothing doesn't work
* Do we have a reason to use JunctionOutPort[+T]? I added +T
  only for symmetry reasons with JunctionInPort[-T].
 2014-10-01 13:25:02 +02:00
Patrik Nordwall
c272d9afa5 Merge pull request #16004 from akka/wip-15875-unzip-patriknw 
+str #15875 Hook-up unzip operation in the new Streams DSL
 2014-10-01 10:02:00 +02:00
Patrik Nordwall
ce96065222 +str #15875 Hook-up unzip operation in the new Streams DSL 
* handle output ports in FlowGraph
 2014-10-01 10:01:14 +02:00
Patrik Nordwall
412263da4d Merge pull request #16005 from akka/wip-15960-FlowGraph-variance-patriknw 
+str #15960 Correction of FlowGraph variance
 2014-10-01 09:58:28 +02:00
Patrik Nordwall
bd352df0b2 +str #15960 Correction of FlowGraph variance 2014-10-01 09:56:44 +02:00
Patrik Nordwall
d89d9abf49 Merge pull request #15999 from akka/wip-15996-unordered-mapFuture-patriknw 
+str #15996 Add unorderedMapAsync
 2014-10-01 09:54:33 +02:00
Patrik Nordwall
2b0565d81e +str #15996 Add mapAsyncUnordered 
* rename mapFuture to mapAsync
* add mapAsyncUnordered
* extract common things for emits to a trait
 2014-10-01 09:49:46 +02:00
Patrik Nordwall
7da2273497 Merge pull request #15997 from akka/wip-15900-fanout-actor-name-patriknw 
=str #15900 Make fanout publisher actor name unique
 2014-10-01 09:43:14 +02:00
Patrik Nordwall
1555fca655 Merge pull request #15994 from akka/wip-15892-ClassCastException-ThunkSource-patriknw 
=str #15892 Fix ClassCastException in ThunkSource
 2014-10-01 09:42:29 +02:00
Björn Antonsson
4cf76cff2e Merge pull request #15986 from akka/wip-15945-clean-up-unbind-ban 
!str,hco #15945 Make creation of ServerBinding public again
 2014-09-29 16:52:25 +02:00
Patrik Nordwall
66f86b6e9b =str #15892 Fix ClassCastException in ThunkSource 
* and add test
 2014-09-29 16:07:13 +02:00
Patrik Nordwall
da5c4c4594 =str #15900 Make fanout publisher actor name unique 2014-09-29 16:05:31 +02:00
Björn Antonsson
ea3198e6e5 !str,hco #15945 Make creation of ServerBinding public again 2014-09-29 15:12:40 +02:00
Björn Antonsson
386c3ba815 Merge pull request #15983 from akka/wip-15945-unbind-tcp-and-http-connection-ban 
+hco #15945 Make Tcp and Http server binding closeable
 2014-09-26 13:31:41 +02:00
Björn Antonsson
e62945654f +hco #15945 Make Tcp and Http server binding closeable 2014-09-26 12:03:25 +02:00
Björn Antonsson
ad1ad44fcc Merge pull request #15975 from spray/wip-15962-mathias 
Remove `Deferrable[T]` and replace with POF (plain old Future)
 2014-09-26 11:27:34 +02:00
Björn Antonsson
49f2e8bcf5 Merge pull request #15969 from spray/wip-15490-mathias 
Improve handling of `Transfer-Encoding` header
 2014-09-26 06:25:02 +02:00
Mathias
36904eadcb =htc Improve handling of Transfer-Encoding header, closes #15490 2014-09-25 16:53:44 +02:00
Mathias
0afebd1c39 !htc Tighten up header model some more, update spec links 2014-09-25 16:48:03 +02:00
Mathias
a2cf6cf228 !htc Remove obsolete ProtectedHeaderCreation construct 2014-09-25 16:48:03 +02:00
drewhk
82d4963382 Merge pull request #15940 from drewhk/wip-15498-dont-close-after-head-closedelimited-drewhk 
Implement transparent HEAD support
 2014-09-25 15:22:01 +02:00
Endre Sándor Varga
8fad19c88c +hco #15498: Transparent HEAD support 
- don't close on HEAD request when sending CloseDelimited
 2014-09-25 15:21:17 +02:00
Björn Antonsson
fb96a2964b Merge pull request #15967 from spray/w/15635-http-remove-all-global-state 
!hco #15635 reorganize registration of predefined, custom HTTP primitives + other small improvements
 2014-09-25 15:12:03 +02:00