Reveretd parameter name

Author: abdheshkumar

src/main/scala/com/lightbend/kafka/scala/streams/KGroupedTableS.scala

@@ -34,26 +34,26 @@ class KGroupedTableS[K, V](inner: KGroupedTable[K, V]) {
   }
 
   def reduce(adder: (V, V) => V,
-             subTractor: (V, V) => V,
+             subtractor: (V, V) => V,
              materialized: Materialized[K, V, ByteArrayKVStore]): KTableS[K, V] = {
 
     // need this explicit asReducer for Scala 2.11 or else the SAM conversion doesn't take place
     // works perfectly with Scala 2.12 though
-    inner.reduce(((v1, v2) => adder(v1, v2)).asReducer, ((v1, v2) => subTractor(v1, v2)).asReducer, materialized)
+    inner.reduce(((v1, v2) => adder(v1, v2)).asReducer, ((v1, v2) => subtractor(v1, v2)).asReducer, materialized)
   }
 
   def aggregate[VR](initializer: () => VR,
                     adder: (K, V, VR) => VR,
-                    subTractor: (K, V, VR) => VR): KTableS[K, VR] = {
+                    subtractor: (K, V, VR) => VR): KTableS[K, VR] = {
 
-    inner.aggregate(initializer.asInitializer, adder.asAggregator, subTractor.asAggregator)
+    inner.aggregate(initializer.asInitializer, adder.asAggregator, subtractor.asAggregator)
   }
 
   def aggregate[VR](initializer: () => VR,
                     adder: (K, V, VR) => VR,
-                    subTractor: (K, V, VR) => VR,
+                    subtractor: (K, V, VR) => VR,
                     materialized: Materialized[K, VR, ByteArrayKVStore]): KTableS[K, VR] = {
 
-    inner.aggregate(initializer.asInitializer, adder.asAggregator, subTractor.asAggregator, materialized)
+    inner.aggregate(initializer.asInitializer, adder.asAggregator, subtractor.asAggregator, materialized)
   }
 }