folder refactoring

Author: Taiye Ogunlade

src/main/java/chap1/FakerDemo.java renamed to src/main/java/content/chap1/FakerDemo.java

@@ -1,4 +1,4 @@
-package chap1;
+package content.chap1;
 
 import com.github.javafaker.Faker;
 

src/main/java/chap1/Lec01Stream.java renamed to src/main/java/content/chap1/Lec01Stream.java

@@ -1,4 +1,4 @@
-package chap1;
+package content.chap1;
 
 import java.util.stream.Stream;
 

src/main/java/chap1/Lec03MonoSubscribe.java renamed to src/main/java/content/chap1/Lec03MonoSubscribe.java

@@ -1,7 +1,7 @@
-package chap1;
+package content.chap1;
 
 import reactor.core.publisher.Mono;
-import utility.Util;
+import content.utility.Util;
 
 public class Lec03MonoSubscribe {
 

src/main/java/chap1/Lec04MonoEmptyOrError.java renamed to src/main/java/content/chap1/Lec04MonoEmptyOrError.java

@@ -1,7 +1,7 @@
-package chap1;
+package content.chap1;
 
 import reactor.core.publisher.Mono;
-import utility.Util;
+import content.utility.Util;
 
 public class Lec04MonoEmptyOrError {
 

src/main/java/chap1/Lec05MonoFromSupplier.java renamed to src/main/java/content/chap1/Lec05MonoFromSupplier.java

@@ -1,7 +1,7 @@
-package chap1;
+package content.chap1;
 
 import reactor.core.publisher.Mono;
-import utility.Util;
+import content.utility.Util;
 
 import java.util.concurrent.Callable;
 import java.util.function.Supplier;

src/main/java/chap1/Lec06SupplierRefactoring.java renamed to src/main/java/content/chap1/Lec06SupplierRefactoring.java

@@ -1,9 +1,8 @@
-package chap1;
+package content.chap1;
 
 import reactor.core.publisher.Mono;
-import reactor.core.scheduler.Scheduler;
 import reactor.core.scheduler.Schedulers;
-import utility.Util;
+import content.utility.Util;
 
 public class Lec06SupplierRefactoring {
 

src/main/java/chap1/Lec07MonoFromFuture.java renamed to src/main/java/content/chap1/Lec07MonoFromFuture.java

@@ -1,7 +1,7 @@
-package chap1;
+package content.chap1;
 
 import reactor.core.publisher.Mono;
-import utility.Util;
+import content.utility.Util;
 
 import java.util.concurrent.CompletableFuture;
 

src/main/java/chap1/Lec08MonoFromRunnable.java renamed to src/main/java/content/chap1/Lec08MonoFromRunnable.java

@@ -1,7 +1,7 @@
-package chap1;
+package content.chap1;
 
 import reactor.core.publisher.Mono;
-import utility.Util;
+import content.utility.Util;
 
 public class Lec08MonoFromRunnable {
 

src/main/java/chap1/Lec09FileServiceAssignment.java renamed to src/main/java/content/chap1/Lec09FileServiceAssignment.java

@@ -1,7 +1,7 @@
-package chap1;
+package content.chap1;
 
-import chap1.assignment.FileService;
-import utility.Util;
+import content.chap1.assignment.FileService;
+import content.utility.Util;
 
 import java.util.ArrayList;
 import java.util.List;

src/main/java/chap1/Lec2Mono.java renamed to src/main/java/content/chap1/Lec2Mono.java

@@ -1,4 +1,4 @@
-package chap1;
+package content.chap1;
 
 import reactor.core.publisher.Mono;
 

src/main/java/chap1/assignment/FileService.java renamed to src/main/java/content/chap1/assignment/FileService.java

@@ -1,4 +1,4 @@
-package chap1.assignment;
+package content.chap1.assignment;
 
 import reactor.core.publisher.Mono;
 

src/main/java/chap2/Lec01FluxIntro.java renamed to src/main/java/content/chap2/Lec01FluxIntro.java

@@ -1,7 +1,7 @@
-package chap2;
+package content.chap2;
 
 import reactor.core.publisher.Flux;
-import utility.Util;
+import content.utility.Util;
 
 public class Lec01FluxIntro {
 

src/main/java/chap2/Lec02MultipleSubscriber.java renamed to src/main/java/content/chap2/Lec02MultipleSubscriber.java

@@ -1,4 +1,4 @@
-package chap2;
+package content.chap2;
 
 import reactor.core.publisher.Flux;
 

src/main/java/chap2/Lec03FluxFromArrayOrList.java renamed to src/main/java/content/chap2/Lec03FluxFromArrayOrList.java

@@ -1,7 +1,7 @@
-package chap2;
+package content.chap2;
 
 import reactor.core.publisher.Flux;
-import utility.Util;
+import content.utility.Util;
 
 import java.util.Arrays;
 import java.util.List;

src/main/java/chap2/Lec04FluxFromStream.java renamed to src/main/java/content/chap2/Lec04FluxFromStream.java

@@ -1,7 +1,7 @@
-package chap2;
+package content.chap2;
 
 import reactor.core.publisher.Flux;
-import utility.Util;
+import content.utility.Util;
 
 import java.util.List;
 import java.util.stream.Stream;

src/main/java/chap2/Lec05FluxRange.java renamed to src/main/java/content/chap2/Lec05FluxRange.java

@@ -1,7 +1,7 @@
-package chap2;
+package content.chap2;
 
 import reactor.core.publisher.Flux;
-import utility.Util;
+import content.utility.Util;
 
 public class Lec05FluxRange {
 

src/main/java/chap2/Lec06Subscription.java renamed to src/main/java/content/chap2/Lec06Subscription.java

@@ -1,9 +1,9 @@
-package chap2;
+package content.chap2;
 
 import org.reactivestreams.Subscriber;
 import org.reactivestreams.Subscription;
 import reactor.core.publisher.Flux;
-import utility.Util;
+import content.utility.Util;
 
 import java.util.concurrent.atomic.AtomicReference;
 

src/main/java/chap2/Lec07FluxVsList.java renamed to src/main/java/content/chap2/Lec07FluxVsList.java

@@ -1,7 +1,7 @@
-package chap2;
+package content.chap2;
 
-import chap2.helper.NameGenerator;
-import utility.Util;
+import content.chap2.helper.NameGenerator;
+import content.utility.Util;
 
 
 public class Lec07FluxVsList {

src/main/java/chap2/Lec08Interval.java renamed to src/main/java/content/chap2/Lec08Interval.java

@@ -1,7 +1,7 @@
-package chap2;
+package content.chap2;
 
 import reactor.core.publisher.Flux;
-import utility.Util;
+import content.utility.Util;
 
 import java.time.Duration;
 

src/main/java/chap2/Lec20StockPrices.java renamed to src/main/java/content/chap2/Lec20StockPrices.java

@@ -1,6 +1,6 @@
-package chap2;
+package content.chap2;
 
-import chap2.assignment.StockPricePublisher;
+import content.chap2.assignment.StockPricePublisher;
 import org.reactivestreams.Subscriber;
 import org.reactivestreams.Subscription;
 

src/main/java/chap2/Lec9FluxFromMono.java renamed to src/main/java/content/chap2/Lec9FluxFromMono.java

@@ -1,8 +1,8 @@
-package chap2;
+package content.chap2;
 
 import reactor.core.publisher.Flux;
 import reactor.core.publisher.Mono;
-import utility.Util;
+import content.utility.Util;
 
 public class Lec9FluxFromMono {
 

src/main/java/chap2/assignment/StockPricePublisher.java renamed to src/main/java/content/chap2/assignment/StockPricePublisher.java

@@ -1,7 +1,7 @@
-package chap2.assignment;
+package content.chap2.assignment;
 
 import reactor.core.publisher.Flux;
-import utility.Util;
+import content.utility.Util;
 
 import java.time.Duration;
 import java.util.concurrent.atomic.AtomicInteger;

src/main/java/chap2/helper/NameGenerator.java renamed to src/main/java/content/chap2/helper/NameGenerator.java

@@ -1,10 +1,7 @@
-package chap2.helper;
+package content.chap2.helper;
 
 import reactor.core.publisher.Flux;
-import utility.Util;
-
-import java.util.ArrayList;
-import java.util.List;
+import content.utility.Util;
 
 public class NameGenerator {
 

src/main/java/chap3/Lec01FluxCreate.java renamed to src/main/java/content/chap3/Lec01FluxCreate.java

@@ -1,7 +1,7 @@
-package chap3;
+package content.chap3;
 
 import reactor.core.publisher.Flux;
-import utility.Util;
+import content.utility.Util;
 
 public class Lec01FluxCreate {
 

src/main/java/chap3/Lec02FluxCreateRefactor.java renamed to src/main/java/content/chap3/Lec02FluxCreateRefactor.java

@@ -1,8 +1,8 @@
-package chap3;
+package content.chap3;
 
-import chap3.helper.NameProducer;
+import content.chap3.helper.NameProducer;
 import reactor.core.publisher.Flux;
-import utility.Util;
+import content.utility.Util;
 
 public class Lec02FluxCreateRefactor {
 

src/main/java/chap3/Lec04FluxCreateIssueFixed.java renamed to src/main/java/content/chap3/Lec04FluxCreateIssueFixed.java

@@ -1,7 +1,7 @@
-package chap3;
+package content.chap3;
 
 import reactor.core.publisher.Flux;
-import utility.Util;
+import content.utility.Util;
 
 public class Lec04FluxCreateIssueFixed {
     public static void main(String[] args) {

src/main/java/chap3/Lec06FluxGenerateUtil.java renamed to src/main/java/content/chap3/Lec06FluxGenerateUtil.java

@@ -1,7 +1,7 @@
-package chap3;
+package content.chap3;
 
 import reactor.core.publisher.Flux;
-import utility.Util;
+import content.utility.Util;
 
 
 public class Lec06FluxGenerateUtil {

src/main/java/chap3/Lec07FluxGeneratorCounter.java renamed to src/main/java/content/chap3/Lec07FluxGeneratorCounter.java

@@ -1,7 +1,7 @@
-package chap3;
+package content.chap3;
 
 import reactor.core.publisher.Flux;
-import utility.Util;
+import content.utility.Util;
 
 public class Lec07FluxGeneratorCounter {
 

src/main/java/chap3/Lec08FluxPush.java renamed to src/main/java/content/chap3/Lec08FluxPush.java

@@ -1,8 +1,8 @@
-package chap3;
+package content.chap3;
 
-import chap3.helper.NameProducer;
+import content.chap3.helper.NameProducer;
 import reactor.core.publisher.Flux;
-import utility.Util;
+import content.utility.Util;
 
 public class Lec08FluxPush {
     public static void main(String[] args) {

src/main/java/chap3/Lec09FileServiceAssignment.java renamed to src/main/java/content/chap3/Lec09FileServiceAssignment.java

@@ -1,13 +1,10 @@
-package chap3;
+package content.chap3;
 
-import chap1.assignment.FileService;
-import chap3.assignment.FileReaderService;
-import utility.Util;
+import content.chap3.assignment.FileReaderService;
+import content.utility.Util;
 
 import java.nio.file.Path;
 import java.nio.file.Paths;
-import java.util.ArrayList;
-import java.util.List;
 
 public class Lec09FileServiceAssignment {
 

src/main/java/chap3/Lect03FluxTake.java renamed to src/main/java/content/chap3/Lect03FluxTake.java

@@ -1,4 +1,4 @@
-package chap3;
+package content.chap3;
 
 import reactor.core.publisher.Flux;
 

src/main/java/chap3/Lect05FluxGenerate.java renamed to src/main/java/content/chap3/Lect05FluxGenerate.java

@@ -1,7 +1,7 @@
-package chap3;
+package content.chap3;
 
 import reactor.core.publisher.Flux;
-import utility.Util;
+import content.utility.Util;
 
 public class Lect05FluxGenerate {
 

src/main/java/chap3/assignment/FileReaderService.java renamed to src/main/java/content/chap3/assignment/FileReaderService.java

@@ -1,4 +1,4 @@
-package chap3.assignment;
+package content.chap3.assignment;
 
 import reactor.core.publisher.Flux;
 import reactor.core.publisher.SynchronousSink;

src/main/java/chap3/helper/NameProducer.java renamed to src/main/java/content/chap3/helper/NameProducer.java

@@ -1,7 +1,7 @@
-package chap3.helper;
+package content.chap3.helper;
 
 import reactor.core.publisher.FluxSink;
-import utility.Util;
+import content.utility.Util;
 
 import java.util.function.Consumer;
 

src/main/java/chap4/Lec01Handle.java renamed to src/main/java/content/chap4/Lec01Handle.java

@@ -1,7 +1,7 @@
-package chap4;
+package content.chap4;
 
 import reactor.core.publisher.Flux;
-import utility.Util;
+import content.utility.Util;
 
 public class Lec01Handle {
     public static void main(String[] args) {

src/main/java/chap4/Lec02CallBack.java renamed to src/main/java/content/chap4/Lec02CallBack.java

@@ -1,7 +1,7 @@
-package chap4;
+package content.chap4;
 
 import reactor.core.publisher.Flux;
-import utility.Util;
+import content.utility.Util;
 
 public class Lec02CallBack {
     public static void main(String[] args) {

src/main/java/chap4/Lec03LimitRate.java renamed to src/main/java/content/chap4/Lec03LimitRate.java

@@ -1,7 +1,7 @@
-package chap4;
+package content.chap4;
 
 import reactor.core.publisher.Flux;
-import utility.Util;
+import content.utility.Util;
 
 public class Lec03LimitRate {
 

src/main/java/chap4/Lec05Delay.java renamed to src/main/java/content/chap4/Lec05Delay.java

@@ -1,7 +1,7 @@
-package chap4;
+package content.chap4;
 
 import reactor.core.publisher.Flux;
-import utility.Util;
+import content.utility.Util;
 
 import java.time.Duration;
 

src/main/java/chap4/Lec06OnError.java renamed to src/main/java/content/chap4/Lec06OnError.java

@@ -1,8 +1,8 @@
-package chap4;
+package content.chap4;
 
 import reactor.core.publisher.Flux;
 import reactor.core.publisher.Mono;
-import utility.Util;
+import content.utility.Util;
 
 public class Lec06OnError {
 

src/main/java/chap4/Lec07TimeOut.java renamed to src/main/java/content/chap4/Lec07TimeOut.java

@@ -1,7 +1,7 @@
-package chap4;
+package content.chap4;
 
 import reactor.core.publisher.Flux;
-import utility.Util;
+import content.utility.Util;
 
 import java.time.Duration;