#8: Support for multiple Compressors and Decompressors

Author: andreilisa

spring-grpc-spring-boot-autoconfigure/src/main/java/org/springframework/grpc/autoconfigure/common/codec/GrpcCodecAutoConfiguration.java

@@ -1,13 +1,12 @@
 package org.springframework.grpc.autoconfigure.common.codec;
 
-import io.grpc.Codec;
-import io.grpc.CompressorRegistry;
-import io.grpc.DecompressorRegistry;
+import io.grpc.*;
 import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
-import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 
+import java.util.List;
+
 /**
  * The autoconfiguration that contains all codec related beans for clients/servers.
  *
@@ -17,25 +16,17 @@
 @ConditionalOnClass(Codec.class)
 public class GrpcCodecAutoConfiguration {
 
-	@ConditionalOnMissingBean
-	@Bean
-	public Codec gzipCompressor() {
-		return new Codec.Gzip();
-	}
-
-	@ConditionalOnMissingBean
 	@Bean
-	public CompressorRegistry defaultCompressorRegistry(Codec codec) {
-		final CompressorRegistry registry = CompressorRegistry.getDefaultInstance();
-		registry.register(codec);
+	public CompressorRegistry compressorRegistry(List<Compressor> compressors) {
+		CompressorRegistry registry = CompressorRegistry.getDefaultInstance();
+		compressors.forEach(registry::register);
 		return registry;
 	}
 
-	@ConditionalOnMissingBean
 	@Bean
-	public DecompressorRegistry defaultDecompressorRegistry(Codec codec) {
+	public DecompressorRegistry decompressorRegistry(List<Decompressor> decompressors) {
 		DecompressorRegistry registry = DecompressorRegistry.getDefaultInstance();
-		registry = registry.with(codec, false);
+		decompressors.forEach(decompressor -> registry.with(decompressor, false));
 		return registry;
 	}