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

1526 commits

This branch
This branch
All branches
Author SHA1 Message Date
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
Konrad Malawski
37aa2cb886 Merge pull request #17088 from ktoso/fix-typo-port-ktoso 
=doc fix typo: form -> from
 2015-03-30 10:04:39 +02:00
Jun
a9a7a799fc =doc fix typo: form -> from 
Ports #17074 to the right branch
 2015-03-30 10:02:50 +02:00
drewhk
dd4b9986bc Merge pull request #17085 from drewhk/wip-16924-flowspec-terminated-fanout-fix-drewhk 
=str #16924: Fix FanoutProcessor to not overwrite last termination cause
 2015-03-27 15:24:15 +01:00
Endre Sándor Varga
5559c34ca9 =str #16924: Fix FanoutProcessor to not overwrite last termination cause 
Also fix FlowSpec to expect onError instead of onComplete for late subscribers
 2015-03-27 14:53:04 +01:00
Roland Kuhn
74cba3693d Merge pull request #17083 from 2m/wip-server-binding-docs 
=doc #16989 update http bind documentation
 2015-03-27 14:01:03 +01:00
Patrik Nordwall
7081b6b9d4 Merge pull request #17035 from RichardBradley/17008-TcpStreamActor-leak 
=str #17008 Close the TcpConnectionStream on failure.
 2015-03-27 11:31:23 +01:00
Patrik Nordwall
add5f39d18 Merge pull request #17047 from spray/wip-16816-mathias 
+htp #16816 Add variants of `conditional` directive taking only ETag or only Last-Modified value.
 2015-03-27 11:30:21 +01:00
Patrik Nordwall
b6fc0d150b Merge pull request #17061 from bantonsson/wip-16938-GraphConcatSpec-ban 
=str #16938 Enable more tests in GraphConcatSpec
 2015-03-27 10:22:11 +01: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
Konrad Malawski
a382071ed7 Merge pull request #17042 from ktoso/wip-16972-bindandhandle-renames 
!htc #16972 harmonize naming - bindAndHandle...
 2015-03-25 15:53:24 +01:00
Patrik Nordwall
c83986e74d Merge pull request #17052 from wjur/fix/empty_authority 
=htc #16954 Fix handling of empty authority in Uris
 2015-03-25 14:56:05 +01:00
Björn Antonsson
164869c135 =str #16938 Enable more tests in GraphConcatSpec 2015-03-24 14:41:17 +01:00
Roland Kuhn
354b52f62f Merge pull request #16995 from akka/wip-bidi-dsl-∂π 
!str #16416,#16994 BidiFlow DSL and Flow.join Mat
 2015-03-24 11:37:44 +01:00
Roland Kuhn
4a7814af91 Merge pull request #17001 from spray/wip-16988-mathias 
!htc #16988 hide model.parser.HeaderParser from public API, add proper `HeaderParser.parse`
 2015-03-24 11:13:31 +01: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
Wojciech Jurczyk
f468d7c426 =htc #16954 Fix handling of empty authority in Uris 2015-03-18 21:07:34 +01:00
Mathias
85edf72d70 +htp #16816 Add variants of conditional directive taking only ETag or only Last-Modified value 2015-03-17 14:45:02 +01:00
Björn Antonsson
1b52ae333f Merge pull request #17020 from spray/wip-close-tests 
=htc Enable rendering of HTTP/1.0 responses, increase test coverage for connection closing logic
 2015-03-14 16:25:05 -07:00
Konrad Malawski
4a98f8335f !htc #16972 harmonize naming - bindAndHandle... 2015-03-14 11:41:45 -07:00
Roland Kuhn
119ff32f44 Merge pull request #17041 from ktoso/wip-16972-missing-run-in-bindandhandle 
+htc #16972 makes bindAndStartHandlingWith actually run()
 2015-03-14 18:49:29 +01:00
Konrad Malawski
ac6723cba7 +htc #16972 makes bindAndStartHandlingWith actually run() 2015-03-14 09:55:10 -07:00
Richard Bradley
ee298a13c0 =str #17008 Close the TcpConnectionStream on failure. 2015-03-12 15:15:37 +00:00
Roland Kuhn
c383ce46e2 Merge pull request #16954 from spray/wip-16953-mathias 
=htc #16953 Fix handling of empty hosts in Uris
 2015-03-09 13:09:06 +01:00
Roland Kuhn
5827438a2d Merge pull request #16987 from akka/wip-16983-outputBurstLimit-∂π 
!str #16983 add outputBurstLimit
 2015-03-09 12:59:29 +01:00
Roland Kuhn
a531058c04 !str #16983 add outputBurstLimit 
This limits the number of elements that the ActorInterpreter will allow
the OneBoundedInterpreter to emit during one message processing.
 2015-03-08 17:22:44 +01:00
Patrik Nordwall
513882ab22 Merge pull request #17016 from akka/wip-16309-dry-tests-patriknw 
=str #16309 DRY FlowIteratorSpec, FlowIterableSpec, SynchronousIterableS...
 2015-03-06 16:53:37 +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
Patrik Nordwall
9b3d19f451 =str #16309 DRY FlowIteratorSpec, FlowIterableSpec, SynchronousIterableSpec 2015-03-06 16:06:19 +01:00
Mathias
078017bd42 =htc #16953 Fix handling of empty hosts in Uris 2015-03-06 16:05:20 +01:00
Patrik Nordwall
9ea08e0743 Merge pull request #17013 from akka/wip-str-scaladoc-patriknw 
=str Fix some scaladoc
 2015-03-06 15:59:21 +01:00
Patrik Nordwall
f62b161a10 Merge pull request #17009 from akka/wip-16866-fail-future-patriknw 
=str #16866 fail fold and foreach future when function throws
 2015-03-06 15:58:22 +01:00
Patrik Nordwall
320692c775 Merge pull request #17005 from akka/wip-16992-name-param-patriknw 
!str #16992 Rework Source and Sink name parameter
 2015-03-06 15:57:14 +01:00
Mathias
6cf64735fd =htc Enable rendering of HTTP/1.0 responses, increase test coverage for connection closing logic 2015-03-06 14:19:05 +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
71d2db0552 =str Fix some scaladoc 2015-03-06 10:23:26 +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
Patrik Nordwall
395ef00938 =str #16866 fail fold and foreach future when function throws 2015-03-05 18:26:17 +01:00
Patrik Nordwall
53e3dcad06 Merge pull request #17006 from akka/wip-16982-resume-more-than-once-patriknw 
=str #16982 Fix supervision bug when more than one resume/restart
 2015-03-05 18:00:53 +01:00
Patrik Nordwall
ff2c7425bc Merge pull request #16996 from akka/wip-16751-rs-rc3-patriknw 
=str #16751 Update to reactive-streams 1.0-RC3
 2015-03-05 17:59:34 +01:00
Patrik Nordwall
23c533fdd5 =str #16751 Update to reactive-streams 1.0-RC3 
Changed rules:
* 1.9 Always onSubscribe prior to any other signals
* 1.9 NullPointerException if subscriber is null
* 3.17 Long overflow, effectively unbounded instead of onError

Fixed some more things:
* fixed some FIXME
* Long drop and take
* memory leaks in tck tests, use BeforeClass to create ActorSystem
  use AfterClass to shutdown ActorSystem
* more tck tests
* don't emit OnComplete when substream is cancelled
* work around for memory leak in PrefixAndTail
 2015-03-05 17:58:24 +01:00
Patrik Nordwall
ac2a890898 =str correct InterpreterSupervisionSpec 2015-03-05 15:16:37 +01:00
Patrik Nordwall
75087a19f2 =str #16982 Fix supervision bug when more than one resume/restart 2015-03-05 14:45:34 +01:00
Mathias
6352fbae81 !htc #16988 hide model.parser.HeaderParser from public API, add proper HeaderParser.parse 2015-03-05 11:36:30 +01:00
Mathias
533583a68d =htc add missing private markers to internal parser sub-traits 2015-03-05 11:36:30 +01:00
Mathias
e53867b1d8 =htc small internal member naming improvement 2015-03-05 11:36:29 +01:00
Björn Antonsson
e3e01d2c9b Merge pull request #16976 from spray/wip-16934-mathias 
HTTP: s/ActorFlowMaterializer/FlowMaterializer/ where possible
 2015-03-04 15:46:19 +01:00
Mathias
ef208bfa8b =htp #16934 s/ActorFlowMaterializer/FlowMaterializer where possible, smaller cleanups 2015-03-02 13:52:09 +01:00
Mathias
abea2c88ef =htc #16934 s/ActorFlowMaterializer/FlowMaterializer where possible, smaller cleanups 2015-03-02 13:52:09 +01:00