You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ratis.apache.org by ru...@apache.org on 2020/12/07 06:05:41 UTC
[incubator-ratis] branch master updated: RATIS-1213. Provide a
default implementation for DataStreamApi.stream() (#330)
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 <am...@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);
}