From ec435d3993ce2d27e5cd53ad653cfc1aac741a81 Mon Sep 17 00:00:00 2001
From: Spencer Gibb <spencer@gibb.us>
Date: Tue, 17 Jan 2017 14:46:15 -0700
Subject: [PATCH] polish

---
 .../cloud/gateway/filter/route/HystrixRouteFilter.java       | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git a/src/main/java/org/springframework/cloud/gateway/filter/route/HystrixRouteFilter.java b/src/main/java/org/springframework/cloud/gateway/filter/route/HystrixRouteFilter.java
index 7c8a8616..8bfdc58d 100644
--- a/src/main/java/org/springframework/cloud/gateway/filter/route/HystrixRouteFilter.java
+++ b/src/main/java/org/springframework/cloud/gateway/filter/route/HystrixRouteFilter.java
@@ -33,11 +33,10 @@ public class HystrixRouteFilter implements RouteFilter {
 		return (exchange, chain) -> {
 			try {
 				RouteHystrixCommand command = new RouteHystrixCommand(setter, exchange, chain);
-				final Observable<Void> observable = command.toObservable();
 
 				return Mono.create(s -> {
-					final Subscription subscription = observable.subscribe(s::success, s::error, s::success);
-					s.setCancellation(subscription::unsubscribe);
+					Subscription sub = command.toObservable().subscribe(s::success, s::error, s::success);
+					s.setCancellation(sub::unsubscribe);
 				});
 			} catch (Exception e) {
 				throw new RuntimeException("Error running RouteHystrixCommand: " + commandName, e);