uses method reference

Author: otaviojava

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

@@ -65,7 +65,7 @@ public void flatMapStageShouldOnlySubscribeToOnePublisherAtATime() throws Except
 
 
         CompletionStage<List<Integer>> result = ReactiveStreams.of(1, 2, 3, 4, 5)
-            .flatMapPublisher(id -> new ScheduledPublisher(id, activePublishers, () -> getExecutorService()))
+            .flatMapPublisher(id -> new ScheduledPublisher(id, activePublishers, this::getExecutorService))
             .toList()
             .run(getEngine());
 

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

@@ -64,7 +64,7 @@ public void flatMapStageShouldOnlySubscribeToOnePublisherAtATime() throws Except
         AtomicInteger activePublishers = new AtomicInteger();
 
         CompletionStage<List<Integer>> result = ReactiveStreams.of(1, 2, 3, 4, 5)
-            .flatMap(id -> ReactiveStreams.fromPublisher(new ScheduledPublisher(id, activePublishers, () -> getExecutorService())))
+            .flatMap(id -> ReactiveStreams.fromPublisher(new ScheduledPublisher(id, activePublishers, this::getExecutorService)))
             .toList()
             .run(getEngine());