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

1345 commits

Author SHA1 Message Date
Richard Imaoka
c636f3540f Correct the backpressure API comment for throttle (Fixes #22791) (#23225) 2017-06-27 05:32:53 -07:00
Konrad `ktoso` Malawski
b7d7316c1c =str #22917 recoverWithRetries allow 0 and negative values 2017-06-13 11:18:46 +02:00
Patrik Nordwall
d80f92c25f Merge pull request #23082 from hseeberger/23081-docs-source-queue 
Fix docs for Source.queue (closes #23081)
 2017-06-09 13:15:14 +02:00
Patrik Nordwall
9f14dfad14 Merge pull request #23097 from akka/wip-doc-str-wat-fix-yes 
=str typo in exception, it is getStageActor
 2017-06-09 13:12:08 +02:00
Johannes Rudolph
b3487eabe6 Merge pull request #23110 from jrudolph/jr/fix-source-queue-edge-cases 
=str break out a few source implementations into separate files
 2017-06-08 11:09:18 +02:00
Richard Imaoka
32d1d006c7 Add mentions to akka.stream.impl.package and fix some typos. (Fixes #23073) (#23075) 2017-06-07 01:44:31 -07:00
Johannes Rudolph
084b1220ff =str break out a few source implementations into separate files 2017-06-06 16:38:25 +02:00
Johannes Rudolph
3a28584f77 =str gather no stack trace for TcpIdleTimeoutException (#23106) 
Fixes akka/akka-http#1176
 2017-06-06 02:14:45 -07:00
Konrad `ktoso` Malawski
b98bf72f57 =str typo in exception, it is getStageActor 2017-06-05 01:49:02 +02:00
Heiko Seeberger
b929565323 Fix docs for Source.queue (closes #23081) 2017-06-02 10:40:54 +02:00
Richard Imaoka
5d276a730c Fix typo in the comment of completeIfPossible() 2017-05-29 14:44:07 +02:00
Martynas Mickevičius
c840bd6f37 #22808 Move CoupledTerminationFlow to Flow.fromSinkAndSourceCoupled 
Also mention coupled variant in the uncoupled scaladoc
 2017-05-22 16:00:10 +02:00
drewhk
fd0d5324bf Documentation of the new materializer system (#22699) 2017-05-19 13:46:24 +02:00
Johannes Rudolph
38c9fff219 =act #13861 report cause for Akka IO TCP CommandFailed events 
To stay compatible this needs to be hacked into CommandFailed using a
mutable var.
 2017-05-16 15:22:11 +02:00
Hawstein
b3d00afdd1 Move ConstantFun to akka.util, #22813 2017-05-10 18:00:42 +02:00
Age Mooij
2b67d445f2 Fix typos and improved English in scaladoc/javadoc for BroadcastHub (#22852) 2017-05-09 16:11:52 +02:00
Philippus Baalman
ef9c7313b6 Extend copyright into 2017 (#22833) 2017-05-04 15:14:33 +02:00
Gilad Hoch
edee4ba409 +str #22711 adding GroupedWeightedWithin 2017-04-28 15:07:06 +02:00
Johan Andrén
87b28d0dc5 Fail all stages on abrupt termination #22652 2017-04-28 11:11:50 +02:00
Enno
7ca40a8518 Truncated contents in existing files for FileIO.toPath/toFile #22782 2017-04-28 11:05:17 +02:00
Heiko Seeberger
21cc5470fd Fix docs for Sink.last(Option) #22691 2017-04-27 17:31:33 +02:00
Arnout Engelen
c10d03970b Separate dot attributes by comma's (#22786) 2017-04-25 08:07:15 -07:00
Cedric CORBIERE
33ce3f0b77 Add startPosition option for FileIO API 
* New startPosition parameter to FileIO.toPath
* New startPosition parameter to FileIO.fromPath
* default startPosition value : 0
* fix binary compatibilities
* Add the MiMa filters for the internal classes
* Feedback from comments of the PR
 2017-04-21 15:00:39 +02:00
Patrik Nordwall
082507973a Merge pull request #22669 from ktoso/wip-fix-fileio-types 
=str #22666 fix FileIO parameter type to OpenOptions
 2017-04-21 14:11:10 +02:00
Johan Andrén
d5459222aa Substream materialization failure test coverage and fix #22646 2017-04-03 20:21:02 +02:00
Konrad `ktoso` Malawski
7dcea0a4d8 =str #22666 fix FileIO parameter type to OpenOptions 2017-04-01 10:39:44 +02:00
Thomas Alton
626d07edca Schedule timer for remaining delayed elements #22416 2017-03-30 16:27:01 +02:00
Konrad `ktoso` Malawski
5eb1651438 =str #22358 enable test and cleanup FutureFlatten source 2017-03-28 12:55:12 +03:00
虎鸣
e9694edaab =str #22602 short path for Source.fromFuture and fromFutureSource and their alias 2017-03-28 00:39:40 +08:00
Björn Antonsson
f8b4fb55ca Remove use of deprecated Scala features #22581 2017-03-27 19:05:54 +03:00
Patrik Nordwall
191bd0fe41 =str #22584 make subfusing work if diff materialize() is called 
Also: removed unecessary method with wrong name, #22350
 2017-03-17 12:42:13 +01:00
Patrik Nordwall
c3c058b6bb Merge pull request #22360 from johanandren/wip-21363-future-source-last-bit-johanandren 
Source that flattens a future source and keeps mat val
 2017-03-16 20:36:05 +01:00
Patrik Nordwall
22dedd1ffa Merge pull request #22565 from johanandren/wip-fix-mat-dep-warning-johanandren 
A few warnings fixed
 2017-03-16 20:33:07 +01:00
Martynas Mickevičius
2a9c0370e0 Add @InternalApi annotations and private markers on internal apis (#22563) 
* #22506 Mark materializer extension as @InternalApi

* #22506 Added missing annotations on internal apis in the fusing package

* #22506 Missing annotations in io package

* #22506 Add internal api annotations in impl package

* #22563 more hiding of the classes in the impl package

* #22563 Formatting fixes

* #22506 Fix private access in stream tcl tests
 2017-03-16 20:04:07 +01:00
Patrik Nordwall
6414aaccbc small change in method dispatch that seems to impact bench results (#22564) 2017-03-16 10:27:59 +01:00
Johan Andrén
d51f7abd63 Give a good error message on unassigned ports #22552 2017-03-15 18:03:52 +01:00
Patrik Nordwall
e4a09c207f Merge pull request #22480 from manonthegithub/wip-22446-fix-merge-preferred-ordering 
#22446 fixed corruption of ordering in MergePreferred
 2017-03-15 16:21:30 +01:00
Johannes Rudolph
70253fab3f Merge pull request #22559 from jrudolph/jr/w/22554-fix-CCE-in-SubSink 
=str #22554 fix ClassCastException in SubSink
 2017-03-15 15:26:18 +01:00
Johan Andrén
39199b877a Fix some build and compile warnings 2017-03-15 14:26:41 +01:00
Johannes Rudolph
5b9295b3f0
=str #22554 fix ClassCastException in SubSink 
Fixes #22554.
 2017-03-15 12:07:52 +01:00
Johan Andrén
3f0c23e2da Fail framing stage if length field is less than 0 #22367 2017-03-15 11:13:13 +01:00
Johan Andrén
60d918c490 Deprecate auto-fusing setting #22431 2017-03-15 09:15:18 +01:00
Kirill Yankov
5704c72ece fixed corruption of ordering in MergePreferred caused by using emit() with emit in andThen() callback #22446 2017-03-14 23:42:48 +03:00
Johannes Rudolph
c5076a3b9a =str formatting fix 2017-03-14 17:22:48 +01:00
Sergey
ba213b7fee GroupedWithin cold emit fix (#22407) 
* groupedWithin cold emit fix

* lowered numbers in tests; removed meaningless assertions
 2017-03-14 13:45:45 +01:00
Patrik Nordwall
e77c3c3e8a Merge pull request #22551 from akka/wip-lazy-TraversalBuilder-patriknw 
remove lazy from TraversalBuilder field
 2017-03-14 13:29:49 +01:00
Johan Andrén
d6bf003127 Provide materialized value even if downstream cancels. 2017-03-14 12:55:32 +01:00
Johan Andrén
2dc7fcd651 More complete test coverage, bug and code style fixes 2017-03-14 12:54:20 +01:00
Johan Andrén
5bf69979c3 Handle sub interpreters not being initialized when debug dumping graph 2017-03-14 12:54:01 +01:00
cchantep
5b542d99fa Flatten a Future[Graph[SourceShape[T], M]] as Source[T, Future[M]] #22359 2017-03-14 12:54:01 +01:00