fixed test problems

Author: chengyouling

foundations/foundation-vertx/src/test/java/org/apache/servicecomb/foundation/vertx/TestStream.java

@@ -53,7 +53,7 @@ public void testBufferOutputStream() {
     Assertions.assertTrue((1 < oBufferOutputStream.length()));
 
     @SuppressWarnings("resource")
-    BufferInputStream oBufferInputStream = new BufferInputStream(oBufferOutputStream.getByteBuf());
+    BufferInputStream oBufferInputStream = new BufferInputStream(oBufferOutputStream.getBuffer().getByteBuf());
     Assertions.assertEquals("test", oBufferInputStream.readString());
     Assertions.assertEquals(1, oBufferInputStream.readByte());
     Assertions.assertEquals(true, oBufferInputStream.readBoolean());

foundations/foundation-vertx/src/test/java/org/apache/servicecomb/foundation/vertx/client/tcp/TestTcpClientConnection.java

@@ -32,6 +32,7 @@
 import io.vertx.core.Context;
 import io.vertx.core.Handler;
 import io.vertx.core.Promise;
+import io.vertx.core.buffer.Buffer;
 import io.vertx.core.net.NetSocket;
 import io.vertx.core.net.impl.NetSocketImpl;
 import mockit.Deencapsulation;
@@ -90,14 +91,14 @@ public void send_inWorkingStatus(@Mocked AbstractTcpClientPackage tcpClientPacka
     Deencapsulation.setField(tcpClientConnection, "status", Status.WORKING);
 
     long msgId = 1;
-    ByteBuf byteBuf = Unpooled.buffer();
+    Buffer byteBuf = Buffer.buffer();
     new Expectations(tcpClientConnection) {
       {
         tcpClientPackage.getMsgId();
         result = msgId;
         tcpClientPackage.createStream();
         result = tcpOutputStream;
-        tcpOutputStream.getByteBuf();
+        tcpOutputStream.getBuffer();
         result = byteBuf;
       }
     };
@@ -172,7 +173,7 @@ public void send_disconnectedToWorking(@Mocked AbstractTcpClientPackage tcpClien
       {
         tcpClientPackage.getMsgId();
         result = msgId;
-        tcpClientConnection.write((ByteBuf) any);
+        tcpClientConnection.write((Buffer) any);
       }
     };
     new MockUp<Context>(context) {

transports/transport-rest/transport-rest-client/src/main/java/org/apache/servicecomb/transport/rest/client/http/RestClientInvocation.java

@@ -220,7 +220,7 @@ protected void handleResponse(HttpClientResponse httpClientResponse) {
       return;
     }
 
-    if (restOperationMeta.isServerSendEvents()) {
+    if (restOperationMeta != null && restOperationMeta.isServerSendEvents()) {
       processFlowableResponseBody(FlowableHelper.toFlowable(httpClientResponse));
       return;
     }