-
Notifications
You must be signed in to change notification settings - Fork 143
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
Add missing java api for StreamTestKit #1186
Conversation
812f1ea
to
650ef9d
Compare
@@ -136,15 +136,15 @@ class StreamTestKitSpec extends PekkoSpec { | |||
// It also needs to be dilated since the testkit will dilate the timeout | |||
// accordingly to `-Dpekko.test.timefactor` value. | |||
val initialDelay = (timeout * 2).dilated | |||
val pf: PartialFunction[Any, Unit] = { |
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.
these changes seem quite small compared to the StreamTestKit changes
is it possible to test all the new functions?
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.
Sorry, I'm a little busy at $Work right now, testing all these new methods seems like a lot of work, and as we can see, the changes are mostly small, just forwarding/converting.
@@ -1242,8 +1242,7 @@ public void mustBeAbleToUseMerge3() { | |||
.mergeAll(Arrays.asList(sourceB, sourceC), false) | |||
.runWith(TestSink.probe(system), system); | |||
sub.expectSubscription().request(9); | |||
sub.expectNextUnorderedN(Util.immutableSeq(Arrays.asList(1, 2, 3, 4, 5, 6, 7, 8, 9))) | |||
.expectComplete(); | |||
sub.expectNextUnorderedN(Arrays.asList(1, 2, 3, 4, 5, 6, 7, 8, 9)).expectComplete(); |
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.
Then, no Util.immutableSeq
is needed
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.
This is getting a lgtm. Adding tests for these functions are not necessary since they are basic wrappers over existing functions which are already being tested and this has also historically been the case for Akka as well
@pjfanning @Roiocam WDYT, should it be included in m1 release? |
Lgtm |
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.
Lgtm
Thanks |
Motivation:
Add more java native api to StreamTestKit.
refs:#970
was: #1049
continue the work of @naosense