grpc
/
grpc-java
mirror of https://github.com/grpc/grpc-java.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

core: hide RetriableStream type from ClientTransportProvider

This commit is contained in:
ZHANG Dapeng 2018-12-12 10:04:39 -08:00 committed by GitHub
parent 23dadaa85d
commit 0cf91e333b
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
4 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
core/src/main/java/io/grpc/internal/ClientCallImpl.java
View File

@ -128,7 +128,7 @@ final class ClientCallImpl<ReqT, RespT> extends ClientCall<ReqT, RespT> {
*/ */
ClientTransport get(PickSubchannelArgs args); ClientTransport get(PickSubchannelArgs args);
<ReqT> RetriableStream<ReqT> newRetriableStream( <ReqT> ClientStream newRetriableStream(
MethodDescriptor<ReqT, ?> method, MethodDescriptor<ReqT, ?> method,
CallOptions callOptions, CallOptions callOptions,
Metadata headers, Metadata headers,
@ -416,7 +416,7 @@ final class ClientCallImpl<ReqT, RespT> extends ClientCall<ReqT, RespT> {
try { try {
if (stream instanceof RetriableStream) { if (stream instanceof RetriableStream) {
@SuppressWarnings("unchecked") @SuppressWarnings("unchecked")
RetriableStream<ReqT> retriableStream = ((RetriableStream<ReqT>) stream); RetriableStream<ReqT> retriableStream = (RetriableStream<ReqT>) stream;
retriableStream.sendMessage(message); retriableStream.sendMessage(message);
} else { } else {
stream.writeMessage(method.streamRequest(message)); stream.writeMessage(method.streamRequest(message));

2
core/src/main/java/io/grpc/internal/ManagedChannelImpl.java
View File

@ -470,7 +470,7 @@ final class ManagedChannelImpl extends ManagedChannel implements
} }
@Override @Override
public <ReqT> RetriableStream<ReqT> newRetriableStream( public <ReqT> ClientStream newRetriableStream(
final MethodDescriptor<ReqT, ?> method, final MethodDescriptor<ReqT, ?> method,
final CallOptions callOptions, final CallOptions callOptions,
final Metadata headers, final Metadata headers,

2
core/src/main/java/io/grpc/internal/OobChannel.java
View File

@ -92,7 +92,7 @@ final class OobChannel extends ManagedChannel implements InternalInstrumented<Ch
} }
@Override @Override
public <ReqT> RetriableStream<ReqT> newRetriableStream(MethodDescriptor<ReqT, ?> method, public <ReqT> ClientStream newRetriableStream(MethodDescriptor<ReqT, ?> method,
CallOptions callOptions, Metadata headers, Context context) { CallOptions callOptions, Metadata headers, Context context) {
throw new UnsupportedOperationException("OobChannel should not create retriable streams"); throw new UnsupportedOperationException("OobChannel should not create retriable streams");
} }

2
core/src/main/java/io/grpc/internal/SubchannelChannel.java
View File

@ -60,7 +60,7 @@ final class SubchannelChannel extends Channel {
} }
@Override @Override
public <ReqT> RetriableStream<ReqT> newRetriableStream(MethodDescriptor<ReqT, ?> method, public <ReqT> ClientStream newRetriableStream(MethodDescriptor<ReqT, ?> method,
CallOptions callOptions, Metadata headers, Context context) { CallOptions callOptions, Metadata headers, Context context) {
throw new UnsupportedOperationException("OobChannel should not create retriable streams"); throw new UnsupportedOperationException("OobChannel should not create retriable streams");
} }