He-Pin commented on code in PR #1049:
URL: https://github.com/apache/incubator-pekko/pull/1049#discussion_r1467430680
##########
stream-testkit/src/main/scala/org/apache/pekko/stream/testkit/StreamTestKit.scala:
##########
@@ -818,11 +886,35 @@ object TestSubscriber {
*/
def within[T](min: FiniteDuration, max: FiniteDuration)(f: => T): T =
probe.within(min, max)(f)
+ /**
+ * Execute code block while bounding its execution time between `min` and
+ * `max`. `within` blocks may be nested. All methods in this trait which
+ * take maximum wait times are available in a version which implicitly uses
+ * the remaining time governed by the innermost enclosing `within` block.
+ *
+ * Note that the timeout is scaled using Duration.dilated, which uses the
+ * configuration entry "pekko.test.timefactor", while the min Duration is
not.
+ *
+ * {{{
+ * val ret = within(50 millis) {
Review Comment:
delete or rewrite this code as java:)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
