Fixes #199

Wrong metric event was being used.
ReactiveX · Aug 20, 2014 · 5d94327 · 5d94327
1 parent 7b57bae
commit 5d94327
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/rx-netty/src/main/java/io/reactivex/netty/channel/DefaultChannelWriter.java b/rx-netty/src/main/java/io/reactivex/netty/channel/DefaultChannelWriter.java
@@ -127,7 +127,7 @@ public void call() {
                                .doOnError(new Action1<Throwable>() {
                                    @Override
                                    public void call(Throwable throwable) {
-                                       eventsSubject.onEvent(metricEventProvider.getFlushSuccessEvent(),
+                                       eventsSubject.onEvent(metricEventProvider.getFlushFailedEvent(),
                                                              Clock.onEndMillis(startTimeMillis), throwable);
                                    }
                                });