Remove context push in RequestContextScala*.call()

Author: ikhoon

rxjava/src/main/java/com/linecorp/armeria/common/rxjava/RequestContextScalarSupplierFlowable.java

@@ -52,8 +52,6 @@ protected void subscribeActual(Subscriber<? super T> s) {
     @SuppressWarnings("unchecked")
     @Override
     public T get() {
-        try (SafeCloseable ignored = assemblyContext.push()) {
-            return ((ScalarSupplier<T>) source).get();
-        }
+        return ((ScalarSupplier<T>) source).get();
     }
 }

rxjava/src/main/java/com/linecorp/armeria/common/rxjava/RequestContextScalarSupplierMaybe.java

@@ -44,8 +44,6 @@ protected void subscribeActual(MaybeObserver<? super T> s) {
     @Override
     @SuppressWarnings("unchecked")
     public T get() {
-        try (SafeCloseable ignored = assemblyContext.push()) {
-            return ((ScalarSupplier<T>) source).get();
-        }
+        return ((ScalarSupplier<T>) source).get();
     }
 }

rxjava/src/main/java/com/linecorp/armeria/common/rxjava/RequestContextScalarSupplierObservable.java

@@ -44,8 +44,6 @@ protected void subscribeActual(Observer<? super T> s) {
     @SuppressWarnings("unchecked")
     @Override
     public T get() {
-        try (SafeCloseable ignored = assemblyContext.push()) {
-            return ((ScalarSupplier<T>) source).get();
-        }
+        return ((ScalarSupplier<T>) source).get();
     }
 }

rxjava/src/main/java/com/linecorp/armeria/common/rxjava/RequestContextScalarSupplierSingle.java

@@ -44,8 +44,6 @@ protected void subscribeActual(SingleObserver<? super T> s) {
     @SuppressWarnings("unchecked")
     @Override
     public T get() {
-        try (SafeCloseable ignored = assemblyContext.push()) {
-            return ((ScalarSupplier<T>) source).get();
-        }
+        return ((ScalarSupplier<T>) source).get();
     }
 }

rxjava2/src/main/java/com/linecorp/armeria/common/rxjava2/RequestContextScalarCallableCompletable.java

@@ -45,8 +45,6 @@ protected void subscribeActual(CompletableObserver s) {
     @SuppressWarnings("unchecked")
     @Override
     public T call() {
-        try (SafeCloseable ignored = assemblyContext.push()) {
-            return ((ScalarCallable<T>) source).call();
-        }
+        return ((ScalarCallable<T>) source).call();
     }
 }

rxjava2/src/main/java/com/linecorp/armeria/common/rxjava2/RequestContextScalarCallableFlowable.java

@@ -53,8 +53,6 @@ protected void subscribeActual(Subscriber<? super T> s) {
     @SuppressWarnings("unchecked")
     @Override
     public T call() {
-        try (SafeCloseable ignored = assemblyContext.push()) {
-            return ((ScalarCallable<T>) source).call();
-        }
+        return ((ScalarCallable<T>) source).call();
     }
 }

rxjava2/src/main/java/com/linecorp/armeria/common/rxjava2/RequestContextScalarCallableMaybe.java

@@ -44,8 +44,6 @@ protected void subscribeActual(MaybeObserver<? super T> s) {
     @SuppressWarnings("unchecked")
     @Override
     public T call() {
-        try (SafeCloseable ignored = assemblyContext.push()) {
-            return ((ScalarCallable<T>) source).call();
-        }
+        return ((ScalarCallable<T>) source).call();
     }
 }

rxjava2/src/main/java/com/linecorp/armeria/common/rxjava2/RequestContextScalarCallableObservable.java

@@ -44,8 +44,6 @@ protected void subscribeActual(Observer<? super T> s) {
     @SuppressWarnings("unchecked")
     @Override
     public T call() {
-        try (SafeCloseable ignored = assemblyContext.push()) {
-            return ((ScalarCallable<T>) source).call();
-        }
+        return ((ScalarCallable<T>) source).call();
     }
 }

rxjava2/src/main/java/com/linecorp/armeria/common/rxjava2/RequestContextScalarCallableSingle.java

@@ -44,8 +44,6 @@ protected void subscribeActual(SingleObserver<? super T> s) {
     @SuppressWarnings("unchecked")
     @Override
     public T call() {
-        try (SafeCloseable ignored = assemblyContext.push()) {
-            return ((ScalarCallable<T>) source).call();
-        }
+        return ((ScalarCallable<T>) source).call();
     }
 }