[servicecomb-java-chassis] branch master updated: [SCB-2493] Bump rxjava from 1.1.6 to 1.3.8 (#2856)

[liubao]

This is an automated email from the ASF dual-hosted git repository.

liubao pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/servicecomb-java-chassis.git


The following commit(s) were added to refs/heads/master by this push:
     new c8e429f81 [SCB-2493] Bump rxjava from 1.1.6 to 1.3.8 (#2856)
c8e429f81 is described below

commit c8e429f810828735393c8709e4e0fecd5be2b52c
Author: ZhangJian He <shoot...@gmail.com>
AuthorDate: Wed May 11 14:12:34 2022 +0800

    [SCB-2493] Bump rxjava from 1.1.6 to 1.3.8 (#2856)
---
 dependencies/default/pom.xml                                          | 2 +-
 .../main/java/org/apache/servicecomb/bizkeeper/BizkeeperCommand.java  | 4 ++--
 .../org/apache/servicecomb/bizkeeper/BizkeeperHandlerDelegate.java    | 2 +-
 3 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/dependencies/default/pom.xml b/dependencies/default/pom.xml
index 755d141c3..2707d2df2 100644
--- a/dependencies/default/pom.xml
+++ b/dependencies/default/pom.xml
@@ -93,7 +93,7 @@
     <protostuff-parser.version>2.2.25</protostuff-parser.version>
     <resilience4j.versioin>1.7.0</resilience4j.versioin>
     <ribbon.version>2.7.18</ribbon.version>
-    <rxjava.version>1.1.6</rxjava.version>
+    <rxjava.version>1.3.8</rxjava.version>
     <rxnetty.version>0.5.1</rxnetty.version>
     <seanyinx.version>1.0.0</seanyinx.version>
     <servo.version>0.12.25</servo.version>
diff --git 
a/handlers/handler-bizkeeper/src/main/java/org/apache/servicecomb/bizkeeper/BizkeeperCommand.java
 
b/handlers/handler-bizkeeper/src/main/java/org/apache/servicecomb/bizkeeper/BizkeeperCommand.java
index 7b7703ebd..ac64bbffe 100644
--- 
a/handlers/handler-bizkeeper/src/main/java/org/apache/servicecomb/bizkeeper/BizkeeperCommand.java
+++ 
b/handlers/handler-bizkeeper/src/main/java/org/apache/servicecomb/bizkeeper/BizkeeperCommand.java
@@ -62,7 +62,7 @@ public abstract class BizkeeperCommand extends 
HystrixObservableCommand<Response
   @Override
   protected Observable<Response> resumeWithFallback() {
     Throwable cause = getFailedExecutionException();
-    Observable<Response> observable = Observable.create(f -> {
+    Observable<Response> observable = Observable.unsafeCreate(f -> {
       try {
         f.onNext(FallbackPolicyManager.getFallbackResponse(type, cause, 
invocation));
         f.onCompleted();
@@ -81,7 +81,7 @@ public abstract class BizkeeperCommand extends 
HystrixObservableCommand<Response
 
   @Override
   protected Observable<Response> construct() {
-    return Observable.create(f -> {
+    return Observable.unsafeCreate(f -> {
       try {
         invocation.next(resp -> {
           if (isFailedResponse(resp)) {
diff --git 
a/handlers/handler-bizkeeper/src/main/java/org/apache/servicecomb/bizkeeper/BizkeeperHandlerDelegate.java
 
b/handlers/handler-bizkeeper/src/main/java/org/apache/servicecomb/bizkeeper/BizkeeperHandlerDelegate.java
index a1be09d15..389fc0414 100644
--- 
a/handlers/handler-bizkeeper/src/main/java/org/apache/servicecomb/bizkeeper/BizkeeperHandlerDelegate.java
+++ 
b/handlers/handler-bizkeeper/src/main/java/org/apache/servicecomb/bizkeeper/BizkeeperHandlerDelegate.java
@@ -54,7 +54,7 @@ public class BizkeeperHandlerDelegate {
 
       @Override
       public Observable<Response> toObservable() {
-        return Observable.create(f -> {
+        return Observable.unsafeCreate(f -> {
           try {
             
f.onNext(FallbackPolicyManager.getFallbackResponse(handler.groupname, null, 
invocation));
           } catch (Exception e) {