testing: move NoopClientCall & NoopServerCall to internal

one step for #3105
This commit is contained in:
ZHANG Dapeng 2017-06-22 15:10:58 -07:00 committed by GitHub
parent 6d9e149dcb
commit b7e50ddd05
9 changed files with 126 additions and 7 deletions

View File

@ -29,7 +29,7 @@ import static org.junit.Assert.assertTrue;
import static org.junit.Assert.fail; import static org.junit.Assert.fail;
import io.grpc.internal.FakeClock; import io.grpc.internal.FakeClock;
import io.grpc.testing.NoopServerCall; import io.grpc.internal.NoopServerCall;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.Arrays; import java.util.Arrays;
import java.util.List; import java.util.List;

View File

@ -30,7 +30,7 @@ import static org.mockito.Mockito.verifyZeroInteractions;
import io.grpc.MethodDescriptor.Marshaller; import io.grpc.MethodDescriptor.Marshaller;
import io.grpc.MethodDescriptor.MethodType; import io.grpc.MethodDescriptor.MethodType;
import io.grpc.ServerCall.Listener; import io.grpc.ServerCall.Listener;
import io.grpc.testing.NoopServerCall; import io.grpc.internal.NoopServerCall;
import java.io.ByteArrayInputStream; import java.io.ByteArrayInputStream;
import java.io.InputStream; import java.io.InputStream;
import java.util.ArrayList; import java.util.ArrayList;

View File

@ -31,7 +31,7 @@ import io.grpc.ServerServiceDefinition;
import io.grpc.ServiceDescriptor; import io.grpc.ServiceDescriptor;
import io.grpc.Status; import io.grpc.Status;
import io.grpc.StatusRuntimeException; import io.grpc.StatusRuntimeException;
import io.grpc.testing.NoopServerCall; import io.grpc.internal.NoopServerCall;
import io.grpc.testing.TestMethodDescriptors; import io.grpc.testing.TestMethodDescriptors;
import java.util.Arrays; import java.util.Arrays;
import org.junit.Test; import org.junit.Test;

View File

@ -30,7 +30,7 @@ import io.grpc.Channel;
import io.grpc.ClientCall; import io.grpc.ClientCall;
import io.grpc.Deadline; import io.grpc.Deadline;
import io.grpc.MethodDescriptor; import io.grpc.MethodDescriptor;
import io.grpc.testing.NoopClientCall; import io.grpc.internal.NoopClientCall;
import io.grpc.testing.integration.Messages.SimpleRequest; import io.grpc.testing.integration.Messages.SimpleRequest;
import io.grpc.testing.integration.Messages.SimpleResponse; import io.grpc.testing.integration.Messages.SimpleResponse;
import io.grpc.testing.integration.TestServiceGrpc; import io.grpc.testing.integration.TestServiceGrpc;

View File

@ -37,9 +37,9 @@ import io.grpc.Status;
import io.grpc.StatusRuntimeException; import io.grpc.StatusRuntimeException;
import io.grpc.inprocess.InProcessChannelBuilder; import io.grpc.inprocess.InProcessChannelBuilder;
import io.grpc.inprocess.InProcessServerBuilder; import io.grpc.inprocess.InProcessServerBuilder;
import io.grpc.internal.NoopClientCall;
import io.grpc.stub.ServerCalls.NoopStreamObserver; import io.grpc.stub.ServerCalls.NoopStreamObserver;
import io.grpc.stub.ServerCallsTest.IntegerMarshaller; import io.grpc.stub.ServerCallsTest.IntegerMarshaller;
import io.grpc.testing.NoopClientCall;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.Arrays; import java.util.Arrays;
import java.util.Iterator; import java.util.Iterator;

View File

@ -0,0 +1,51 @@
/*
* Copyright 2016, gRPC Authors All rights reserved.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package io.grpc.internal;
import io.grpc.ClientCall;
import io.grpc.Metadata;
/**
* {@link NoopClientCall} is a class that is designed for use in tests. It is designed to be used
* in places where a scriptable call is necessary. By default, all methods are noops, and designed
* to be overriden.
*/
public class NoopClientCall<ReqT, RespT> extends ClientCall<ReqT, RespT> {
/**
* {@link NoopClientCall.NoopClientCallListener} is a class that is designed for use in tests.
* It is designed to be used in places where a scriptable call listener is necessary. By
* default, all methods are noops, and designed to be overriden.
*/
public static class NoopClientCallListener<T> extends ClientCall.Listener<T> {
}
@Override
public void start(ClientCall.Listener<RespT> listener, Metadata headers) {}
@Override
public void request(int numMessages) {}
@Override
public void cancel(String message, Throwable cause) {}
@Override
public void halfClose() {}
@Override
public void sendMessage(ReqT message) {}
}

View File

@ -0,0 +1,60 @@
/*
* Copyright 2016, gRPC Authors All rights reserved.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package io.grpc.internal;
import io.grpc.Metadata;
import io.grpc.MethodDescriptor;
import io.grpc.ServerCall;
import io.grpc.Status;
/**
* {@link NoopServerCall} is a class that is designed for use in tests. It is designed to be used
* in places where a scriptable call is necessary. By default, all methods are noops, and designed
* to be overriden.
*/
public class NoopServerCall<ReqT, RespT> extends ServerCall<ReqT, RespT> {
/**
* {@link NoopServerCall.NoopServerCallListener} is a class that is designed for use in tests.
* It is designed to be used in places where a scriptable call listener is necessary. By
* default, all methods are noops, and designed to be overriden.
*/
public static class NoopServerCallListener<T> extends ServerCall.Listener<T> {
}
@Override
public void request(int numMessages) {}
@Override
public void sendHeaders(Metadata headers) {}
@Override
public void sendMessage(RespT message) {}
@Override
public void close(Status status, Metadata trailers) {}
@Override
public boolean isCancelled() {
return false;
}
@Override
public MethodDescriptor<ReqT, RespT> getMethodDescriptor() {
return null;
}
}

View File

@ -24,7 +24,11 @@ import io.grpc.Metadata;
* {@link NoopClientCall} is a class that is designed for use in tests. It is designed to be used * {@link NoopClientCall} is a class that is designed for use in tests. It is designed to be used
* in places where a scriptable call is necessary. By default, all methods are noops, and designed * in places where a scriptable call is necessary. By default, all methods are noops, and designed
* to be overriden. * to be overriden.
*
* @deprecated moved to {@link io.grpc.internal.NoopClientCall} and for internal use only. Please
* use {@link GrpcServerRule} to test on InProcess channels instead
*/ */
@Deprecated
@ExperimentalApi("https://github.com/grpc/grpc-java/issues/2234") @ExperimentalApi("https://github.com/grpc/grpc-java/issues/2234")
public class NoopClientCall<ReqT, RespT> extends ClientCall<ReqT, RespT> { public class NoopClientCall<ReqT, RespT> extends ClientCall<ReqT, RespT> {
@ -33,6 +37,7 @@ public class NoopClientCall<ReqT, RespT> extends ClientCall<ReqT, RespT> {
* It is designed to be used in places where a scriptable call listener is necessary. By * It is designed to be used in places where a scriptable call listener is necessary. By
* default, all methods are noops, and designed to be overriden. * default, all methods are noops, and designed to be overriden.
*/ */
@Deprecated
public static class NoopClientCallListener<T> extends ClientCall.Listener<T> { public static class NoopClientCallListener<T> extends ClientCall.Listener<T> {
} }
@ -51,4 +56,3 @@ public class NoopClientCall<ReqT, RespT> extends ClientCall<ReqT, RespT> {
@Override @Override
public void sendMessage(ReqT message) {} public void sendMessage(ReqT message) {}
} }

View File

@ -26,7 +26,11 @@ import io.grpc.Status;
* {@link NoopServerCall} is a class that is designed for use in tests. It is designed to be used * {@link NoopServerCall} is a class that is designed for use in tests. It is designed to be used
* in places where a scriptable call is necessary. By default, all methods are noops, and designed * in places where a scriptable call is necessary. By default, all methods are noops, and designed
* to be overriden. * to be overriden.
*
* @deprecated moved to {@link io.grpc.internal.NoopServerCall} and for internal use only. Please
* use {@link GrpcServerRule} to test on InProcess channels instead
*/ */
@Deprecated
@ExperimentalApi("https://github.com/grpc/grpc-java/issues/2234") @ExperimentalApi("https://github.com/grpc/grpc-java/issues/2234")
public class NoopServerCall<ReqT, RespT> extends ServerCall<ReqT, RespT> { public class NoopServerCall<ReqT, RespT> extends ServerCall<ReqT, RespT> {
@ -35,6 +39,7 @@ public class NoopServerCall<ReqT, RespT> extends ServerCall<ReqT, RespT> {
* It is designed to be used in places where a scriptable call listener is necessary. By * It is designed to be used in places where a scriptable call listener is necessary. By
* default, all methods are noops, and designed to be overriden. * default, all methods are noops, and designed to be overriden.
*/ */
@Deprecated
public static class NoopServerCallListener<T> extends ServerCall.Listener<T> { public static class NoopServerCallListener<T> extends ServerCall.Listener<T> {
} }
@ -60,4 +65,3 @@ public class NoopServerCall<ReqT, RespT> extends ServerCall<ReqT, RespT> {
return null; return null;
} }
} }