[WIP] Initialized Akka.Streams #1727
Merged
Conversation
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
midwork midwork-v2 stream layout + stages + fixed size buffer + blackhole sub StreamManagement impl abstract ActorMaterializer graph interpreter + stage init graph stage completed ack pub/sub actors flow stages Sinks actor processor midwork sinks flows bidi flow, fan-in and -out shapes, graph flexi merge in progress updated Akka.Streams.TestKit [WIP] fusing graph interpreter ready graph stage something about generics updated StreamLayour and ActorMaterializerImpl added actor graph interpreter withouth boundaries impl.fusing.Ops ported StreamOfStreams without PrefixAndTail completed PrefixAndTail completed Timers and Unfold throttle implemented reimplemented symbolic stages started converting flow operations API stubs for flow ops requiring graph DSL
… BoundedBuffer Updated Sinks implementations Started with the FanOut
|
Can't tell what branch this is going into on mobile, but it absolutely should not be going into 'dev'. Please create a feature branch for Akka-streams and send this into that |
|
|
ah, thanks @Horusiath - I couldn't see that on mobile. Thanks for letting me know! |
Aaronontheweb
added a commit
that referenced
this pull request
Feb 29, 2016
[WIP] Initialized Akka.Streams
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
This PR contains group work on porting the Akka streams module to .NET. It includes several new projects, including:
System.Reactive.Streams- collection of interfaces used to implement reactive streams. Independent from akka itself.Akka.Streams- core streams project.Akka.Streams.TestKit- test kit project to make streams testing easier.Akka.Streams.TestKit.Tests- tests for the stream test kit itself.Akka.Streams.Tests- akka streams test - still a lot of work to do here. At the moment none of them passes.StreamsExamples- pet console project working as live streams playground.There are some tests implemented, but they will be failing as this feature is still work in progress.