-
Notifications
You must be signed in to change notification settings - Fork 1k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Stream update 2.4.9 #2335
Stream update 2.4.9 #2335
Conversation
d93c4e6
to
938ca19
Compare
push to a closed out
b4dd375
to
e92e271
Compare
@@ -15,7 +15,7 @@ namespace Akka.Streams.TestKit.Tests | |||
{ | |||
public class TestPublisherSubscriberSpec : AkkaSpec | |||
{ | |||
protected readonly ActorMaterializer Materializer; | |||
private ActorMaterializer Materializer { get; } |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
why you need private property?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
For running this stream.
@@ -30,7 +30,7 @@ public class InterpreterStressSpec : GraphInterpreterSpecKit | |||
private readonly ITestOutputHelper _helper; | |||
|
|||
// GraphStages can be reused | |||
private static readonly Select<int,int> Select = new Select<int, int>(x=>x+1, Deciders.StoppingDecider); | |||
private static readonly Select<int,int> Select = new Select<int, int>(x=>x+1); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Spaces in lambda
@alexvaluyskiy addressed your remarks |
No description provided.