Make HystrixCommand.execute()/queue() and AbstractCommand.observe()/t…

…oObservable() nonfinal
Netflix · Mar 20, 2015 · a899696 · a899696
1 parent 05ea381
commit a899696
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/hystrix-core/src/main/java/com/netflix/hystrix/AbstractCommand.java b/hystrix-core/src/main/java/com/netflix/hystrix/AbstractCommand.java
@@ -307,7 +307,7 @@ protected AbstractCommand(HystrixCommandGroupKey group, HystrixCommandKey key, H
      * @throws IllegalStateException
      *             if invoked more than once
      */
-    final public Observable<R> observe() {
+    public Observable<R> observe() {
         // us a ReplaySubject to buffer the eagerly subscribed-to Observable
         ReplaySubject<R> subject = ReplaySubject.create();
         // eagerly kick off subscription
@@ -342,7 +342,7 @@ final public Observable<R> observe() {
      * @throws IllegalStateException
      *             if invoked more than once
      */
-    final public Observable<R> toObservable() {
+    public Observable<R> toObservable() {
         /* this is a stateful object so can only be used once */
         if (!started.compareAndSet(false, true)) {
             throw new IllegalStateException("This instance can only be executed once. Please instantiate a new instance.");

diff --git a/hystrix-core/src/main/java/com/netflix/hystrix/HystrixCommand.java b/hystrix-core/src/main/java/com/netflix/hystrix/HystrixCommand.java
@@ -330,7 +330,7 @@ public void call(Subscriber<? super R> s) {
      * @throws IllegalStateException
      *             if invoked more than once
      */
-    final public R execute() {
+    public R execute() {
         try {
             return queue().get();
         } catch (Exception e) {
@@ -360,7 +360,7 @@ final public R execute() {
      * @throws IllegalStateException
      *             if invoked more than once
      */
-    final public Future<R> queue() {
+    public Future<R> queue() {
         /*
          * --- Schedulers.immediate()
          *