From d66713f15e5640f134b1771132368f9be6a322b3 Mon Sep 17 00:00:00 2001
From: huangsimin <huangsimin@ecpark.cn>
Date: Thu, 8 Aug 2019 13:44:09 +0800
Subject: [PATCH] block -> subscribe

---
 .../biz/filters/factory/DubboGatewayFilterFactory.java      | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/usergw-service/src/main/java/cn/ecpark/service/usergw/biz/filters/factory/DubboGatewayFilterFactory.java b/usergw-service/src/main/java/cn/ecpark/service/usergw/biz/filters/factory/DubboGatewayFilterFactory.java
index 34d0631..871806c 100644
--- a/usergw-service/src/main/java/cn/ecpark/service/usergw/biz/filters/factory/DubboGatewayFilterFactory.java
+++ b/usergw-service/src/main/java/cn/ecpark/service/usergw/biz/filters/factory/DubboGatewayFilterFactory.java
@@ -142,12 +142,12 @@ public class DubboGatewayFilterFactory extends AbstractGatewayFilterFactory<Dubb
 
                             if (result.getClass() != String.class) {
                                 response.writeWith(Mono.just(response.bufferFactory()
-                                        .wrap(ByteBuffer.wrap(JSON.toJSONString(result).getBytes())))).block();
+                                        .wrap(ByteBuffer.wrap(JSON.toJSONString(result).getBytes())))).subscribe();
                                 return;
                             }
 
                             response.writeWith(Mono.just(
-                                response.bufferFactory().wrap(ByteBuffer.wrap(((String) result).getBytes())))).block();
+                                response.bufferFactory().wrap(ByteBuffer.wrap(((String) result).getBytes())))).subscribe();
 
                             return;
                         }
@@ -156,7 +156,7 @@ public class DubboGatewayFilterFactory extends AbstractGatewayFilterFactory<Dubb
 
                 result = statusCode.getReasonPhrase();
                 response.writeWith(Mono.just(
-                    response.bufferFactory().wrap(ByteBuffer.wrap(((String) result).getBytes())))).block();
+                    response.bufferFactory().wrap(ByteBuffer.wrap(((String) result).getBytes())))).subscribe();
                 return;
             }));
         }