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

135 commits

Author SHA1 Message Date
Heiko Seeberger
b929565323 Fix docs for Source.queue (closes #23081) 2017-06-02 10:40:54 +02:00
Hawstein
b3d00afdd1 Move ConstantFun to akka.util, #22813 2017-05-10 18:00:42 +02:00
cchantep
5b542d99fa Flatten a Future[Graph[SourceShape[T], M]] as Source[T, Future[M]] #22359 2017-03-14 12:54:01 +01:00
Patrik Nordwall
3554ad7243 Merge branch 'master' into wip-traversal-oriented-layout-master-patriknw 2017-03-10 18:16:44 +01:00
Patrik Nordwall
6c8e24cefa fix SinkSpec, and async boundary attribute, #22463 
* let's keep the AsyncBoundary attribute for now,
  makeIsland is done in setAttributes
* fixing SinkSpec and RunnableGraphSpec
 2017-03-08 15:09:40 +01:00
Patrik Nordwall
1a74b43cd6 include initialAttributes of GraphStage, #22463 
* these must also be included via setAttributes because
  because it will create island for async (dispatcher attribute)
* better actor name of GraphStageIsland, we need it in tests for
  lookup of the actor
* this unlocks OutputStreamSourceSpec and InputStreamSinkSpec
 2017-03-08 13:15:49 +01:00
Konrad `ktoso` Malawski
e47dbda154 =str #22448 rewrite Source.empty to GraphStage 2017-03-07 15:13:49 +01:00
drewhk
46b869d041 Fix the case where an identity flow is appended to a Source with materialized value composition (#22442) 2017-03-02 13:44:35 +01:00
Endre Sándor Varga
ba63c7af8d New materializer and layout 2017-03-01 16:18:55 +01:00
Philippus Baalman
6c7085252a extended copyright into 2017 2017-01-04 17:37:15 +01:00
drewhk
108517958e #21955: Fixed the case when identity flow appended to Source combining materialized values (#21956) 2016-12-19 14:14:07 +01:00
Patrik Nordwall
c05bd51b68 format the code 2016-12-09 14:08:13 +01:00
Konrad `ktoso` Malawski
2ea8cd7410 =str deprecate ActorPublisher/Subscriber, use GraphStage (#21952) 
* =str deprecate ActorPublisher/Subscriber, use GraphStage

* =str deprecate Source.actorPublisher / Sink.actorSubscriber

* =str added deprecation note of ActorPublisher,Subscriber
 2016-12-08 17:22:01 +01:00
Patrik Nordwall
e04444567f Speedup pull request validation 
* speedup ActorCreationPerfSpec
* reduce iterations in ConsistencySpec
* tag SupervisorHierarchySpec as LongRunningTest
* various small speedups and tagging in actor-tests
* speedup expectNoMsg in stream-tests
* tag FramingSpec, and reduce iterations
* speedup QueueSourceSpec
* tag some stream-tests
* reduce iterations in persistence.PerformanceSpec
* reduce iterations in some cluster perf tests
* tag RemoteWatcherSpec
* tag InterpreterStressSpec
* remove LongRunning from ClusterConsistentHashingRouterSpec
* sys property to disable multi-jvm tests in test
* actually disable multi-node tests in validatePullRequest
* doc sbt flags in CONTRIBUTING
 2016-11-30 14:31:06 +01:00
Johan "Party Cannon" Andrén
267f31149c Lazy source (#21081) 2016-11-25 16:25:26 +01:00
Andrey Kuznetsov
3bd53c8bc2 fix SourceQueue docs inconsistencies #21852 2016-11-22 14:11:09 +01:00
Patrik Nordwall
aa8c253d14 improve streams actor integration docs, #21698 (#21700) 
* mapAsync + ask should be the first choice
* add missing Source.queue
* prefer actorRefWithAck
* move ActorPublisher and ActorSubscriber to the end
  with additional warning
* fix wrong doc of SourceQueue offer
* and add missing java api
 2016-10-26 10:24:51 +02:00
Patrik Nordwall
359a087674 Merge pull request #21166 from naferx/sink-graphstage 
=str rewrite Sink internal impl as GraphStage
 2016-08-30 10:37:30 +02:00
Cédric Chantepie
efc87af58a FoldAsync op for Flow #18603 2016-08-24 21:02:32 +02:00
Nafer Sanabria
2f85cf0fb8 =str fix up Scaladocs for Source & Sink 2016-08-11 14:37:54 +02:00
Nafer Sanabria
bed69d1002 =str rewrite Sink internal impl as GraphStage 2016-08-09 21:08:31 -05:00
Kam Kasravi
1d692daaad Fixes #20543 GraphStage subtypes should not be private to akka 2016-07-05 17:12:35 -07:00
Alexander Golubev
03395d5739 =str #20229 groupBy should be a Graph stage (#20344) 2016-05-23 10:31:49 +02:00
Tim Harper
b3806cdbfa =doc add important async caveat for Source.actorRef 2016-05-08 21:35:11 -06:00
Patrik Nordwall
0b0a456e28 Merge pull request #20125 from kelebra/19039-kelebra-cycle 
#19039: Added cycle method to Source class.
 2016-04-26 16:47:02 +02:00
Oleksii Tkachuk
78e0a534f4 Fixed 19039 for both scaladsl and javadsl 
19039: Added cycle method to Source class for both scaladsl and javadsl. Test added.
 2016-04-26 07:37:03 -05:00
Rodolphe BELOUIN
936c97051a +str #19782 Transpose a sources sequence (#19795) 2016-04-22 12:04:28 +02:00
Samuel Tardieu
34d51dcd00 Clarify explanation of Source.actorRef termination in embedded doc 
Make it clear that a Success instance (whose payload will be ignored)
must be sent to complete the source, and not the Success companion
object itself.

Use "a" before instances, and remove "a" before PoisonPill object.

The Java documentation has been aligned to the Scala documentation.
 2016-04-19 13:13:23 +02:00
Konrad Malawski
b9ab232cac str #20262 reduce should fail explicitly on empty stream (#20267) 
* str #20262 reduce should fail explicitly on empty stream

* str #20262 document reduce behaviour on empty stream
 2016-04-11 15:36:10 +02:00
Alexander Golubev
69e6052cbe +str #18620 add Source.blocking() for legacy API integration 2016-03-31 10:29:48 -04:00
Endre Sándor Varga
4b76e32058 #19777 OutputTruncation should be only reported if there is proof of it 2016-03-31 13:53:36 +02:00
Roland Kuhn
8a3cf8145b lift mapMaterializedValue to FlowOpsMat 2016-03-24 12:51:39 +01:00
Roland Kuhn
af310411fd add Source.queue termination support, fixes #19877 2016-03-17 12:47:06 +01:00
Roland Kuhn
b255a19374 simplify materialized value computation tree, fixes #20015 
- also fixes materialized value sources for graphs that import zero or
  one graphs, with and without Fusing
 2016-03-16 17:05:46 +01:00
Johannes Rudolph
b6cbc7f13a =all remove unused imports 2016-02-23 20:29:22 +01:00
Johan Andrén
62e30b3c08 Update copyrights and links to the new company name #19851 2016-02-23 12:58:39 +01:00
Roland Kuhn
7b7647435b ensure that graph attributes are not lost 
- this entails making Module.isSealed==true if attributes are set
- also removed Module.nest(), which implied fixing replaceShape to form
  a CompositeModule where CopiedModule was used before (GraphModule and
  TlsModule)
 2016-02-12 10:07:55 +01:00
Johan Andrén
4e49d75ad8 !str #19732 Concise and consistent way to mark async boundaries 2016-02-11 18:20:23 +01:00
Prayag Verma
b7783968a0 =pro #19068 All copyrights ranges and single years updated to a range ending in 2016 2016-01-25 10:20:30 +01:00
Roland Kuhn
4c72495581 #19440 replace Scala Future usage with CompletionStage in javadsl 
This entails:

  * adding akka.pattern.PatternCS.* to enable ask etc. with
    CompletionStage
  * changing RequestContext to offer an ExecutionContextExecutor for the
    CompletionStage.*Async combinators
  * splitting up akka.stream.Queue for JavaDSL consistency
 2016-01-23 18:00:11 +01:00
Roland Kuhn
ba14bb4f3f Merge pull request #19489 from agolubev/agolubev-#18890_polish-Source.queue 
Agolubev #18890 polish source.queue
 2016-01-22 08:39:53 +01:00
Alexander Golubev
a2ab7f29e1 +str #19020 reduce combinator 2016-01-21 22:16:37 -05:00
Alexander Golubev
d5f81e19d1 =str #18890 Polish Source.queue 2016-01-21 13:09:55 -05:00
Endre Sándor Varga
60497f6561 also fix FlowInterleaveSpec 
Also-by: Johan Andrén <johan@markatta.com>
Also-by: Roland Kuhn <rk@rkuhn.info>
Also-by: Martynas Mickevičius <mmartynas@gmail.com>
 2016-01-20 10:01:58 +02:00
Viktor Klang
58510a2b3f Minor streams touchups 2016-01-19 16:14:34 +01:00
Endre Sándor Varga
b217e2e480 #19440 Added scala-java8-compat as a dependency to streams 2016-01-14 12:01:36 +01:00
Roland Kuhn
3267d58e5d Merge pull request #19407 from akka/wip-optimize-repeat-√ 
=str - Change implementation of Source.repeat to use unfold
 2016-01-14 08:09:04 +01:00
Viktor Klang
2b1d22a785 =str - Change implementation of Source.repeat to use unfold 2016-01-12 10:52:09 +01:00
Viktor Klang
d65efc35c7 -str - Removes Source.unfoldInf 
Motivation: Since it can be easily implemented inline on top of unfold
 2016-01-12 10:22:19 +01:00
Viktor Klang
22ccbcea39 =str - Significant simplification of the implementation of Source.unfoldInf 2016-01-12 10:22:12 +01:00