renaming: mapper, condition

Author: mtumilowicz

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

@@ -6,15 +6,15 @@
  * Created by mtumilowicz on 2018-05-21.
  */
 class Step10_FilteringProcessorAnswer<T> extends Step4_ProcessorBaseAnswer<T, T> implements Step7_StreamAnswer<T> {
-    private final Predicate<T> predicate;
+    private final Predicate<T> condition;
 
-    Step10_FilteringProcessorAnswer(Predicate<T> predicate) {
-        this.predicate = predicate;
+    Step10_FilteringProcessorAnswer(Predicate<T> condition) {
+        this.condition = condition;
     }
 
     @Override
     public void onNext(T item) {
-        if (predicate.test(item)) {
+        if (condition.test(item)) {
             submit(item);
         }
 

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

@@ -6,15 +6,15 @@
  * Created by mtumilowicz on 2018-05-21.
  */
 class Step5_MappingProcessorAnswer<In, Out> extends Step4_ProcessorBaseAnswer<In, Out> {
-    private final Function<In, Out> function;
+    private final Function<In, Out> mapper;
 
-    Step5_MappingProcessorAnswer(Function<In, Out> function) {
-        this.function = function;
+    Step5_MappingProcessorAnswer(Function<In, Out> mapper) {
+        this.mapper = mapper;
     }
 
     @Override
     public void onNext(In item) {
-        submit(function.apply(item));
+        submit(mapper.apply(item));
         subscription.request(1);
     }
 }

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

@@ -6,15 +6,15 @@
  * Created by mtumilowicz on 2018-05-21.
  */
 class Step6_FilteringProcessorAnswer<T> extends Step4_ProcessorBaseAnswer<T, T> {
-    private final Predicate<T> predicate;
+    private final Predicate<T> condition;
 
-    Step6_FilteringProcessorAnswer(Predicate<T> predicate) {
-        this.predicate = predicate;
+    Step6_FilteringProcessorAnswer(Predicate<T> condition) {
+        this.condition = condition;
     }
 
     @Override
     public void onNext(T item) {
-        if (predicate.test(item)) {
+        if (condition.test(item)) {
             submit(item);
         }
 

src/main/java/reactive/answer/Step7_StreamAnswer.java

@@ -8,15 +8,15 @@
  * Created by mtumilowicz on 2019-07-29.
  */
 interface Step7_StreamAnswer<In> extends Flow.Publisher<In> {
-    default <R> Step9_MappingProcessorAnswer<In, R> map(Function<In, R> map) {
-        Step9_MappingProcessorAnswer<In, R> processor = new Step9_MappingProcessorAnswer<>(map);
+    default <R> Step9_MappingProcessorAnswer<In, R> map(Function<In, R> mapper) {
+        Step9_MappingProcessorAnswer<In, R> processor = new Step9_MappingProcessorAnswer<>(mapper);
         this.subscribe(processor);
 
         return processor;
     }
 
-    default Step10_FilteringProcessorAnswer<In> filter(Predicate<In> p) {
-        Step10_FilteringProcessorAnswer<In> processor = new Step10_FilteringProcessorAnswer<>(p);
+    default Step10_FilteringProcessorAnswer<In> filter(Predicate<In> condition) {
+        Step10_FilteringProcessorAnswer<In> processor = new Step10_FilteringProcessorAnswer<>(condition);
         this.subscribe(processor);
 
         return processor;

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

@@ -7,15 +7,15 @@
  */
 class Step9_MappingProcessorAnswer<In, Out> extends Step4_ProcessorBaseAnswer<In, Out>
         implements Step7_StreamAnswer<Out> {
-    private final Function<In, Out> function;
+    private final Function<In, Out> mapper;
 
-    Step9_MappingProcessorAnswer(Function<In, Out> function) {
-        this.function = function;
+    Step9_MappingProcessorAnswer(Function<In, Out> mapper) {
+        this.mapper = mapper;
     }
 
     @Override
     public void onNext(In item) {
-        submit(function.apply(item));
+        submit(mapper.apply(item));
         subscription.request(1);
     }
 }

src/main/java/reactive/workshop/Step10_FilteringProcessorWorkshop.java

@@ -6,8 +6,7 @@
  * Created by mtumilowicz on 2018-05-21.
  */
 class Step10_FilteringProcessorWorkshop<T> extends Step6_FilteringProcessorWorkshop<T> implements Step7_StreamWorkshop<T> {
-
-    Step10_FilteringProcessorWorkshop(Predicate<T> predicate) {
-        super(predicate);
+    Step10_FilteringProcessorWorkshop(Predicate<T> condition) {
+        super(condition);
     }
 }

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

@@ -6,10 +6,10 @@
  * Created by mtumilowicz on 2018-05-21.
  */
 class Step5_MappingProcessorWorkshop<In, Out> extends Step4_ProcessorBaseWorkshop<In, Out> {
-    private final Function<In, Out> function;
+    private final Function<In, Out> mapper;
 
-    Step5_MappingProcessorWorkshop(Function<In, Out> function) {
-        this.function = function;
+    Step5_MappingProcessorWorkshop(Function<In, Out> mapper) {
+        this.mapper = mapper;
     }
 
     @Override

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

@@ -6,10 +6,10 @@
  * Created by mtumilowicz on 2018-05-21.
  */
 class Step6_FilteringProcessorWorkshop<T> extends Step4_ProcessorBaseWorkshop<T, T> {
-    private final Predicate<T> predicate;
+    private final Predicate<T> condition;
 
-    Step6_FilteringProcessorWorkshop(Predicate<T> predicate) {
-        this.predicate = predicate;
+    Step6_FilteringProcessorWorkshop(Predicate<T> condition) {
+        this.condition = condition;
     }
 
     @Override

src/main/java/reactive/workshop/Step9_MappingProcessorWorkshop.java

@@ -7,7 +7,7 @@
  */
 class Step9_MappingProcessorWorkshop<In, Out> extends Step5_MappingProcessorWorkshop<In, Out>
         implements Step7_StreamWorkshop<Out> {
-    Step9_MappingProcessorWorkshop(Function<In, Out> function) {
-        super(function);
+    Step9_MappingProcessorWorkshop(Function<In, Out> mapper) {
+        super(mapper);
     }
 }