Remove explicit type

Signed-off-by: Tran Ngoc Nhan <[email protected]>

Author: ngocnhan-tran1996

samples/grpc-oauth2/src/test/java/org/springframework/grpc/sample/GrpcServerApplicationTests.java

@@ -73,7 +73,7 @@ void unauthenticated() {
 	void anonymous() throws Exception {
 		AtomicReference<ServerReflectionResponse> response = new AtomicReference<>();
 		AtomicBoolean error = new AtomicBoolean();
-		StreamObserver<ServerReflectionResponse> responses = new StreamObserver<ServerReflectionResponse>() {
+		StreamObserver<ServerReflectionResponse> responses = new StreamObserver<>() {
 			@Override
 			public void onNext(ServerReflectionResponse value) {
 				response.set(value);

samples/grpc-secure/src/test/java/org/springframework/grpc/sample/GrpcServerApplicationTests.java

@@ -64,7 +64,7 @@ void unauthenticated() {
 	void anonymous() throws Exception {
 		AtomicReference<ServerReflectionResponse> response = new AtomicReference<>();
 		AtomicBoolean error = new AtomicBoolean();
-		StreamObserver<ServerReflectionResponse> responses = new StreamObserver<ServerReflectionResponse>() {
+		StreamObserver<ServerReflectionResponse> responses = new StreamObserver<>() {
 			@Override
 			public void onNext(ServerReflectionResponse value) {
 				response.set(value);

spring-grpc-core/src/main/java/org/springframework/grpc/client/interceptor/security/BasicAuthenticationInterceptor.java

@@ -47,7 +47,7 @@ public BasicAuthenticationInterceptor(String username, String password) {
 	@Override
 	public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall(MethodDescriptor<ReqT, RespT> method,
 			CallOptions callOptions, Channel next) {
-		return new SimpleForwardingClientCall<ReqT, RespT>(next.newCall(method, callOptions)) {
+		return new SimpleForwardingClientCall<>(next.newCall(method, callOptions)) {
 			public void start(ClientCall.Listener<RespT> responseListener, io.grpc.Metadata headers) {
 				headers.put(GrpcSecurity.AUTHORIZATION_KEY,
 						"Basic " + Base64.getEncoder()

spring-grpc-core/src/main/java/org/springframework/grpc/client/interceptor/security/BearerTokenAuthenticationInterceptor.java

@@ -46,7 +46,7 @@ public BearerTokenAuthenticationInterceptor(Supplier<String> token) {
 	@Override
 	public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall(MethodDescriptor<ReqT, RespT> method,
 			CallOptions callOptions, Channel next) {
-		return new SimpleForwardingClientCall<ReqT, RespT>(next.newCall(method, callOptions)) {
+		return new SimpleForwardingClientCall<>(next.newCall(method, callOptions)) {
 			public void start(ClientCall.Listener<RespT> responseListener, io.grpc.Metadata headers) {
 				headers.put(GrpcSecurity.AUTHORIZATION_KEY,
 						"Bearer " + BearerTokenAuthenticationInterceptor.this.token.get());

spring-grpc-core/src/main/java/org/springframework/grpc/server/exception/GrpcExceptionHandlerInterceptor.java

@@ -75,7 +75,7 @@ public <ReqT, RespT> Listener<ReqT> interceptCall(ServerCall<ReqT, RespT> call,
 		}
 		catch (Throwable t) {
 			exceptionHandledServerCall.close(handler.handleException(t).getStatus(), headers(t));
-			listener = new Listener<ReqT>() {
+			listener = new Listener<>() {
 			};
 			return listener;
 		}

spring-grpc-spring-boot-autoconfigure/src/main/java/org/springframework/grpc/autoconfigure/client/ClientPropertiesChannelBuilderCustomizer.java

@@ -61,7 +61,7 @@ public void customize(String authority, T builder) {
 		mapper.from(channel.getKeepAliveTimeout()).to(durationProperty(builder::keepAliveTimeout));
 		mapper.from(channel.getIdleTimeout()).to(durationProperty(builder::idleTimeout));
 		mapper.from(channel.isKeepAliveWithoutCalls()).to(builder::keepAliveWithoutCalls);
-		Map<String, Object> defaultServiceConfig = new HashMap<String, Object>(channel.getServiceConfig());
+		Map<String, Object> defaultServiceConfig = new HashMap<>(channel.getServiceConfig());
 		if (channel.getHealth().isEnabled()) {
 			String serviceNameToCheck = channel.getHealth().getServiceName() != null
 					? channel.getHealth().getServiceName() : "";

spring-grpc-spring-boot-autoconfigure/src/main/java/org/springframework/grpc/autoconfigure/server/GrpcServerAutoConfiguration.java

@@ -91,7 +91,7 @@ <T extends ServerBuilder<T>> ServerBuilderCustomizer<T> decompressionServerConfi
 	@Bean
 	<T extends ServerBuilder<T>> ServerBuilderCustomizer<T> executorServerConfigurer(
 			GrpcServerExecutorProvider provider) {
-		return new ServerBuilderCustomizerImplementation<T>(provider);
+		return new ServerBuilderCustomizerImplementation<>(provider);
 	}
 
 	private final class ServerBuilderCustomizerImplementation<T extends ServerBuilder<T>>