We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent b14b00a commit 9f2c879Copy full SHA for 9f2c879
tck-flow/src/test/java/org/reactivestreams/tck/flow/SubmissionPublisherTest.java
@@ -27,7 +27,7 @@ public SubmissionPublisherTest() {
27
public Flow.Publisher<Integer> createFlowPublisher(final long elements) {
28
final SubmissionPublisher<Integer> sp = new SubmissionPublisher<Integer>();
29
30
- ForkJoinPool.commonPool().submit(new Runnable() {
+ Thread t = new Thread(new Runnable() {
31
@Override
32
public void run() {
33
while (sp.getNumberOfSubscribers() == 0) {
@@ -45,6 +45,8 @@ public void run() {
45
sp.close();
46
}
47
});
48
+ t.setDaemon(true);
49
+ t.start();
50
51
return sp;
52
0 commit comments