Skip to content

Conversation

marcpiechura
Copy link
Contributor

No description provided.

@@ -20,7 +20,7 @@ public abstract class BaseTwoStreamsSetup<TOutputs> : AkkaSpec
{
protected readonly ActorMaterializer Materializer;

public BaseTwoStreamsSetup(ITestOutputHelper output = null) : base(output)
protected BaseTwoStreamsSetup(ITestOutputHelper output = null) : base(output)
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

We have to add APISpec for Streams, because we could have public API breaking changes

@alexvaluyskiy
Copy link
Contributor

LGTM
@Silv3rcircl3 have you planned to squash the commits?

@marcpiechura
Copy link
Contributor Author

@alexvaluyskiy it's not done yet, therefore the [WIP] ;) But I wanted some feedback regarding tests.

@marcpiechura marcpiechura force-pushed the streams_update_2.4.5 branch 2 times, most recently from dbecbb0 to 8c8c9ac Compare September 13, 2016 21:50
@marcpiechura marcpiechura changed the title [WIP] - Streams update to 2.4.5 Streams update to 2.4.5 Sep 13, 2016
@marcpiechura
Copy link
Contributor Author

@alexvaluyskiy this is now ready for review

@Aaronontheweb Aaronontheweb added this to the 1.1.2 milestone Sep 14, 2016
@@ -64,10 +64,8 @@ public void Select_should_not_blow_up_with_high_request_counts()

var subscription = probe.ExpectSubscription();
// TODO increase to 10000 once performance is improved
Copy link
Contributor

@alexvaluyskiy alexvaluyskiy Sep 20, 2016

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

redundant comment

@@ -261,80 +261,6 @@ public void Interpreter_error_handling_should_fail_when_OnPull_throws()
}

[Fact]
public void Interpreter_error_handling_should_resume_when_Filter_throws()
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Why this test was removed?

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

These specs are moved into the corresponding DSL specs (FlowScanSpec, FlowWhereSpec...)

@@ -122,7 +122,7 @@ public abstract class PushStage<TIn, TOut> : PushPullStage<TIn, TOut>
/// @see <see cref="PushPullStage{TIn,TOut}"/>
/// </summary>
[Obsolete("Please use GraphStage instead.")]
public abstract class DetachedStage<TIn, TOut> : AbstractStage<TIn, TOut, IUpstreamDirective, IDownstreamDirective, IDetachedContext<TOut>, ILifecycleContext>
public abstract class DetachedStage<TIn, TOut> : AbstractStage<TIn, TOut, IUpstreamDirective, IDownstreamDirective, IDetachedContext<TOut>>
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Do we really need too many Obsoleted in a beta version?

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I'm not sure for this stage but in general we are still using these obsolete stages internally and will move to GraphStage over time. Once all stages are using GraphStage we can remove them.

@alexvaluyskiy
Copy link
Contributor

@Silv3rcircl3 Could you rebase it please?

@marcpiechura
Copy link
Contributor Author

@alexvaluyskiy rebased

@alexvaluyskiy alexvaluyskiy merged commit af8f56a into akkadotnet:dev Sep 20, 2016
@marcpiechura marcpiechura deleted the streams_update_2.4.5 branch May 15, 2017 22:01
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
Development

Successfully merging this pull request may close these issues.

3 participants