fixed typo, removed empty test

Netflix · May 23, 2016 · 98f96f7 · 98f96f7
1 parent bdfd8f8
commit 98f96f7
Show file tree

Hide file tree

Showing 4 changed files with 7 additions and 15 deletions.
diff --git a/...vent-stream/src/main/java/com/netflix/hystrix/contrib/reactivesocket/EventStreamEnum.java b/...vent-stream/src/main/java/com/netflix/hystrix/contrib/reactivesocket/EventStreamEnum.java
@@ -1,7 +1,7 @@
 package com.netflix.hystrix.contrib.reactivesocket;
 
 
-import com.netflix.hystrix.contrib.reactivesocket.metrics.HystrixCollasperMetricsStream;
+import com.netflix.hystrix.contrib.reactivesocket.metrics.HystrixCollapserMetricsStream;
 import com.netflix.hystrix.contrib.reactivesocket.metrics.HystrixCommandMetricsStream;
 import com.netflix.hystrix.contrib.reactivesocket.metrics.HystrixThreadPoolMetricsStream;
 import com.netflix.hystrix.contrib.reactivesocket.requests.HystrixRequestEventsStream;
@@ -45,7 +45,7 @@ public Observable<Payload> get() {
             return Observable.merge(
                     HystrixCommandMetricsStream.getInstance().get(),
                     HystrixThreadPoolMetricsStream.getInstance().get(),
-                    HystrixCollasperMetricsStream.getInstance().get());
+                    HystrixCollapserMetricsStream.getInstance().get());
         }
     }
 

diff --git a/...etrics/HystrixCollasperMetricsStream.java → ...etrics/HystrixCollapserMetricsStream.java b/...etrics/HystrixCollasperMetricsStream.java → ...etrics/HystrixCollapserMetricsStream.java
@@ -12,14 +12,14 @@
 import java.io.ByteArrayOutputStream;
 import java.util.stream.Stream;
 
-public class HystrixCollasperMetricsStream extends StreamingSupplier<HystrixCollapserMetrics> {
-    private static HystrixCollasperMetricsStream INSTANCE = new HystrixCollasperMetricsStream();
+public class HystrixCollapserMetricsStream extends StreamingSupplier<HystrixCollapserMetrics> {
+    private static HystrixCollapserMetricsStream INSTANCE = new HystrixCollapserMetricsStream();
 
-    private HystrixCollasperMetricsStream() {
+    private HystrixCollapserMetricsStream() {
         super();
     }
 
-    public static HystrixCollasperMetricsStream getInstance() {
+    public static HystrixCollapserMetricsStream getInstance() {
         return INSTANCE;
     }
 

diff --git a/...-stream/src/test/java/com/netflix/hystrix/contrib/reactivesocket/EventStreamEnumTest.java b/...-stream/src/test/java/com/netflix/hystrix/contrib/reactivesocket/EventStreamEnumTest.java
diff --git a/...cs/HystrixCollasperMetricsStreamTest.java → ...cs/HystrixCollapserMetricsStreamTest.java b/...cs/HystrixCollasperMetricsStreamTest.java → ...cs/HystrixCollapserMetricsStreamTest.java
@@ -7,7 +7,7 @@
 import java.nio.ByteBuffer;
 import java.util.concurrent.CountDownLatch;
 
-public class HystrixCollasperMetricsStreamTest {
+public class HystrixCollapserMetricsStreamTest {
 
     @Test
     public void test() throws Exception {