added warning do code that isn't working

thombergs · thombergs · commit 1437ac44291b · 2020-02-03T06:56:10.000+11:00
diff --git a/reactive/src/main/java/io/reflectoring/reactive/batch/ReactiveBatchProcessorV1.java b/reactive/src/main/java/io/reflectoring/reactive/batch/ReactiveBatchProcessorV1.java
@@ -33,6 +33,7 @@ public ReactiveBatchProcessorV1(
   }
 
   public void start() {
+    // WARNING: this code doesn't work as expected
     messageSource.getMessageBatches()
         .subscribeOn(Schedulers.from(Executors.newSingleThreadExecutor()))
         .doOnNext(batch -> logger.log(batch.toString()))
diff --git a/reactive/src/main/java/io/reflectoring/reactive/batch/ReactiveBatchProcessorV2.java b/reactive/src/main/java/io/reflectoring/reactive/batch/ReactiveBatchProcessorV2.java
@@ -33,6 +33,7 @@ public ReactiveBatchProcessorV2(
   }
 
   public void start() {
+    // WARNING: this code doesn't work as expected
     messageSource.getMessageBatches()
         .subscribeOn(Schedulers.from(Executors.newSingleThreadExecutor()))
         .doOnNext(batch -> logger.log(batch.toString()))
diff --git a/reactive/src/main/java/io/reflectoring/reactive/batch/ReactiveBatchProcessorV3.java b/reactive/src/main/java/io/reflectoring/reactive/batch/ReactiveBatchProcessorV3.java
@@ -33,6 +33,7 @@ public ReactiveBatchProcessorV3(
   }
 
   public void start() {
+    // WARNING: this code doesn't work as expected
     Scheduler scheduler = threadPoolScheduler(threads, threadPoolQueueSize);
 
     messageSource.getMessageBatches()

Original file line number	Diff line number	Diff line change
`@@ -33,6 +33,7 @@ public ReactiveBatchProcessorV1(`
`33`	`33`	`}`
`34`	`34`
`35`	`35`	`public void start() {`
	`36`	`+ // WARNING: this code doesn't work as expected`
`36`	`37`	`messageSource.getMessageBatches()`
`37`	`38`	`.subscribeOn(Schedulers.from(Executors.newSingleThreadExecutor()))`
`38`	`39`	`.doOnNext(batch -> logger.log(batch.toString()))`