[incubator-ratis] branch master updated: RATIS-1213. Provide a default implementation for DataStreamApi.stream() (#330)

[runzhiwang]

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

runzhiwang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-ratis.git


The following commit(s) were added to refs/heads/master by this push:
     new 96b1332  RATIS-1213. Provide a default implementation for 
DataStreamApi.stream() (#330)
96b1332 is described below

commit 96b13321bbd5f31eb6b6d9d247e29f0efcc1a448
Author: Rui Wang <amaliu...@users.noreply.github.com>
AuthorDate: Sun Dec 6 22:05:35 2020 -0800

    RATIS-1213. Provide a default implementation for DataStreamApi.stream() 
(#330)
    
    * RATIS-1213. Provide a default implementation for DataStreamApi.stream()
    
    * trigger new CI check
---
 .../src/main/java/org/apache/ratis/client/api/DataStreamApi.java   | 4 +++-
 .../java/org/apache/ratis/client/impl/DataStreamClientImpl.java    | 7 -------
 2 files changed, 3 insertions(+), 8 deletions(-)

diff --git 
a/ratis-client/src/main/java/org/apache/ratis/client/api/DataStreamApi.java 
b/ratis-client/src/main/java/org/apache/ratis/client/api/DataStreamApi.java
index af3c48b..81c84b7 100644
--- a/ratis-client/src/main/java/org/apache/ratis/client/api/DataStreamApi.java
+++ b/ratis-client/src/main/java/org/apache/ratis/client/api/DataStreamApi.java
@@ -38,7 +38,9 @@ import java.nio.ByteBuffer;
  */
 public interface DataStreamApi {
   /** Create a stream to write data. */
-  DataStreamOutput stream();
+  default DataStreamOutput stream() {
+    return stream(null);
+  }
 
   /** Create a stream by providing a customized header message. */
   DataStreamOutput stream(ByteBuffer headerMessage);
diff --git 
a/ratis-client/src/main/java/org/apache/ratis/client/impl/DataStreamClientImpl.java
 
b/ratis-client/src/main/java/org/apache/ratis/client/impl/DataStreamClientImpl.java
index db09b89..86caa76 100644
--- 
a/ratis-client/src/main/java/org/apache/ratis/client/impl/DataStreamClientImpl.java
+++ 
b/ratis-client/src/main/java/org/apache/ratis/client/impl/DataStreamClientImpl.java
@@ -171,13 +171,6 @@ public class DataStreamClientImpl implements 
DataStreamClient {
   }
 
   @Override
-  public DataStreamOutputRpc stream() {
-    final RaftClientRequest request = new RaftClientRequest(clientId, 
dataStreamServer.getId(), groupId,
-        RaftClientImpl.nextCallId(), 
RaftClientRequest.dataStreamRequestType());
-    return new DataStreamOutputImpl(request);
-  }
-
-  @Override
   public DataStreamOutputRpc stream(RaftClientRequest request) {
     return new DataStreamOutputImpl(request);
   }