Skip to content

Commit 951b054

Browse files
committed
removes comments code
1 parent b6a8852 commit 951b054

File tree

1 file changed

+0
-5
lines changed

1 file changed

+0
-5
lines changed

streams/tck/src/main/java/org/eclipse/microprofile/reactive/streams/tck/FlatMapStageVerification.java

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -63,11 +63,6 @@ public void flatMapStageShouldPropagateRuntimeExceptions() {
6363
public void flatMapStageShouldOnlySubscribeToOnePublisherAtATime() throws Exception {
6464
AtomicInteger activePublishers = new AtomicInteger();
6565

66-
// A publisher that publishes one element 100ms after being requested,
67-
// and then completes 100ms later. It also uses activePublishers to ensure
68-
// that it is the only publisher that is subscribed to at any one time.
69-
70-
7166
CompletionStage<List<Integer>> result = ReactiveStreams.of(1, 2, 3, 4, 5)
7267
.flatMap(id -> ReactiveStreams.fromPublisher(new ScheduledPublisher(id, activePublishers, () -> getExecutorService())))
7368
.toList()

0 commit comments

Comments
 (0)