ReplayProcessorTimeBoundAsPublisherTckTest.txt

java.lang.AssertionError: Expected end-of-stream but got element [NotificationLite.Complete]

	at org.testng.Assert.fail(Assert.java:94)
	at org.reactivestreams.tck.TestEnvironment.flop(TestEnvironment.java:117)
	at org.reactivestreams.tck.TestEnvironment$Receptacle.expectCompletion(TestEnvironment.java:921)
	at org.reactivestreams.tck.TestEnvironment$ManualSubscriber.expectCompletion(TestEnvironment.java:455)
	at org.reactivestreams.tck.TestEnvironment$ManualSubscriber.expectCompletion(TestEnvironment.java:443)
	at org.reactivestreams.tck.PublisherVerification$27.run(PublisherVerification.java:1015)
	at org.reactivestreams.tck.PublisherVerification.activePublisherTest(PublisherVerification.java:1092)
	at org.reactivestreams.tck.PublisherVerification.required_spec317_mustSupportACumulativePendingElementCountUpToLongMaxValue(PublisherVerification.java:1006)
	at jdk.internal.reflect.GeneratedMethodAccessor26.invoke(Unknown Source)
	at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.base/java.lang.reflect.Method.invoke(Method.java:564)
	at org.testng.internal.MethodInvocationHelper.invokeMethod(MethodInvocationHelper.java:104)
	at org.testng.internal.Invoker.invokeMethod(Invoker.java:645)
	at org.testng.internal.Invoker.invokeTestMethod(Invoker.java:851)
	at org.testng.internal.Invoker.invokeTestMethods(Invoker.java:1177)
	at org.testng.internal.TestMethodWorker.invokeTestMethods(TestMethodWorker.java:129)
	at org.testng.internal.TestMethodWorker.run(TestMethodWorker.java:112)
	at org.testng.TestRunner.privateRun(TestRunner.java:756)
	at org.testng.TestRunner.run(TestRunner.java:610)
	at org.testng.SuiteRunner.runTest(SuiteRunner.java:387)
	at org.testng.SuiteRunner.runSequentially(SuiteRunner.java:382)
	at org.testng.SuiteRunner.privateRun(SuiteRunner.java:340)
	at org.testng.SuiteRunner.run(SuiteRunner.java:289)
	at org.testng.SuiteRunnerWorker.runSuite(SuiteRunnerWorker.java:52)
	at org.testng.SuiteRunnerWorker.run(SuiteRunnerWorker.java:86)
	at org.testng.TestNG.runSuitesSequentially(TestNG.java:1293)
	at org.testng.TestNG.runSuitesLocally(TestNG.java:1218)
	at org.testng.TestNG.runSuites(TestNG.java:1133)
	at org.testng.TestNG.run(TestNG.java:1104)
	at org.testng.IDEARemoteTestNG.run(IDEARemoteTestNG.java:72)
	at org.testng.RemoteTestNGStarter.main(RemoteTestNGStarter.java:127)

ReplayProcessorTimeBoundAsPublisherTckTest

ManualSubscriber<T> sub = PublisherVerification.this.env.newManualSubscriber(pub);
                sub.request(4611686018427387903L);
                sub.request(4611686018427387903L);
                sub.request(1L);
                sub.nextElements(3L);
                sub.expectCompletion();

                try {
                    PublisherVerification.this.env.verifyNoAsyncErrorsNoDelay();
                } finally {
                    sub.cancel();
                }