@@ -464,13 +464,13 @@ public TestSetup apply(Long aLong) throws Throwable {
464
464
465
465
expectRequest (env .defaultTimeoutMillis (),
466
466
"If the Processor coordinates requests/emissions when having multiple Subscribers"
467
- + " at once, please override doesCoordinatedEmission() in this "
467
+ + " at once, please override doesCoordinatedEmission() to return true in this "
468
468
+ "IdentityProcessorVerification to allow this test to pass." );
469
469
470
470
final T x = sendNextTFromUpstream ();
471
471
expectNextElement (sub1 , x ,
472
472
"If the Processor coordinates requests/emissions when having multiple Subscribers"
473
- + " at once, please override doesCoordinatedEmission() in this "
473
+ + " at once, please override doesCoordinatedEmission() to return true in this "
474
474
+ "IdentityProcessorVerification to allow this test to pass." );
475
475
476
476
sub1 .request (1 );
@@ -757,7 +757,7 @@ public TestSetup apply(Long subscribers) throws Throwable {
757
757
final T z = sendNextTFromUpstream ();
758
758
expectNextElement (sub1 , z ,
759
759
"If the Processor coordinates requests/emissions when having multiple Subscribers"
760
- + " at once, please override doesCoordinatedEmission() in this "
760
+ + " at once, please override doesCoordinatedEmission() to return true in this "
761
761
+ "IdentityProcessorVerification to allow this test to pass." );
762
762
sub2 .expectNone (); // since sub2 hasn't requested anything yet
763
763
0 commit comments