reordering

Author: mtumilowicz

src/main/java/reactive/answer/Step10_FilteringProcessorAnswer.java

@@ -5,7 +5,7 @@
 /**
  * Created by mtumilowicz on 2018-05-21.
  */
-class Step10_FilteringProcessorAnswer<T> extends Step3_ProcessorBaseAnswer<T, T> implements Step7_StreamAnswer<T> {
+class Step10_FilteringProcessorAnswer<T> extends Step4_ProcessorBaseAnswer<T, T> implements Step7_StreamAnswer<T> {
     private final Predicate<T> predicate;
 
     Step10_FilteringProcessorAnswer(Predicate<T> predicate) {

src/main/java/reactive/answer/Step4_NumberPublisherAnswer.java renamed to src/main/java/reactive/answer/Step3_NumberPublisherAnswer.java

@@ -6,7 +6,7 @@
 /**
  * Created by mtumilowicz on 2018-05-21.
  */
-class Step4_NumberPublisherAnswer extends SubmissionPublisher<Integer> {
+class Step3_NumberPublisherAnswer extends SubmissionPublisher<Integer> {
 
     void start() {
         IntStream.iterate(1, i -> i + 1).forEach(i -> {

src/main/java/reactive/answer/Step3_ProcessorBaseAnswer.java renamed to src/main/java/reactive/answer/Step4_ProcessorBaseAnswer.java

@@ -6,7 +6,7 @@
 /**
  * Created by mtumilowicz on 2018-05-21.
  */
-abstract class Step3_ProcessorBaseAnswer<In, Out> extends Step1_SubscriberBaseAnswer<In>
+abstract class Step4_ProcessorBaseAnswer<In, Out> extends Step1_SubscriberBaseAnswer<In>
         implements Flow.Publisher<Out>, Flow.Processor<In, Out> {
     private final SubmissionPublisher<Out> submissionPublisher = new SubmissionPublisher<>();
 

src/main/java/reactive/answer/Step5_MappingProcessorAnswer.java

@@ -5,7 +5,7 @@
 /**
  * Created by mtumilowicz on 2018-05-21.
  */
-class Step5_MappingProcessorAnswer<In, Out> extends Step3_ProcessorBaseAnswer<In, Out> {
+class Step5_MappingProcessorAnswer<In, Out> extends Step4_ProcessorBaseAnswer<In, Out> {
     private final Function<In, Out> function;
 
     Step5_MappingProcessorAnswer(Function<In, Out> function) {

src/main/java/reactive/answer/Step6_FilteringProcessorAnswer.java

@@ -5,7 +5,7 @@
 /**
  * Created by mtumilowicz on 2018-05-21.
  */
-class Step6_FilteringProcessorAnswer<T> extends Step3_ProcessorBaseAnswer<T, T> {
+class Step6_FilteringProcessorAnswer<T> extends Step4_ProcessorBaseAnswer<T, T> {
     private final Predicate<T> predicate;
 
     Step6_FilteringProcessorAnswer(Predicate<T> predicate) {

src/main/java/reactive/answer/Step9_MappingProcessorAnswer.java

@@ -5,7 +5,7 @@
 /**
  * Created by mtumilowicz on 2018-05-21.
  */
-class Step9_MappingProcessorAnswer<In, Out> extends Step3_ProcessorBaseAnswer<In, Out>
+class Step9_MappingProcessorAnswer<In, Out> extends Step4_ProcessorBaseAnswer<In, Out>
         implements Step7_StreamAnswer<Out> {
     private final Function<In, Out> function;
 

src/main/java/reactive/workshop/Step4_NumberPublisherWorkshop.java renamed to src/main/java/reactive/workshop/Step3_NumberPublisherWorkshop.java

@@ -6,7 +6,7 @@
 /**
  * Created by mtumilowicz on 2018-05-21.
  */
-class Step4_NumberPublisherWorkshop extends SubmissionPublisher<Integer> {
+class Step3_NumberPublisherWorkshop extends SubmissionPublisher<Integer> {
 
     void start() {
         // generate infinite stream of numbers, submit and sleep for each number

src/main/java/reactive/workshop/Step3_ProcessorBaseWorkshop.java renamed to src/main/java/reactive/workshop/Step4_ProcessorBaseWorkshop.java

@@ -6,7 +6,7 @@
 /**
  * Created by mtumilowicz on 2018-05-21.
  */
-abstract class Step3_ProcessorBaseWorkshop<In, Out> extends Step1_SubscriberBaseWorkshop<In>
+abstract class Step4_ProcessorBaseWorkshop<In, Out> extends Step1_SubscriberBaseWorkshop<In>
         implements Flow.Publisher<Out>, Flow.Processor<In, Out> {
     // create SubmissionPublisher
 

src/main/java/reactive/workshop/Step5_MappingProcessorWorkshop.java

@@ -5,7 +5,7 @@
 /**
  * Created by mtumilowicz on 2018-05-21.
  */
-class Step5_MappingProcessorWorkshop<In, Out> extends Step3_ProcessorBaseWorkshop<In, Out> {
+class Step5_MappingProcessorWorkshop<In, Out> extends Step4_ProcessorBaseWorkshop<In, Out> {
     private final Function<In, Out> function;
 
     Step5_MappingProcessorWorkshop(Function<In, Out> function) {

src/main/java/reactive/workshop/Step6_FilteringProcessorWorkshop.java

@@ -5,7 +5,7 @@
 /**
  * Created by mtumilowicz on 2018-05-21.
  */
-class Step6_FilteringProcessorWorkshop<T> extends Step3_ProcessorBaseWorkshop<T, T> {
+class Step6_FilteringProcessorWorkshop<T> extends Step4_ProcessorBaseWorkshop<T, T> {
     private final Predicate<T> predicate;
 
     Step6_FilteringProcessorWorkshop(Predicate<T> predicate) {