@@ -139,22 +139,20 @@ public void close() throws Exception {
139139 private FlightClient createFlightClient (@ Nonnull final ClientConfig config ) {
140140 Location location = createLocation (config );
141141
142- final NettyChannelBuilder nettyChannelBuilder ;
143- switch (location .getUri ().getScheme ()) {
144- case LocationSchemes .GRPC :
145- case LocationSchemes .GRPC_INSECURE :
146- case LocationSchemes .GRPC_TLS : {
147- nettyChannelBuilder = NettyChannelBuilder .forTarget (location .getUri ().getHost ());
148- break ;
149- }
150- case LocationSchemes .GRPC_DOMAIN_SOCKET : {
151- nettyChannelBuilder = NettyChannelBuilder .forTarget (location .getUri ().getHost ());
152- setChannelTypeAndEventLoop (nettyChannelBuilder );
153- break ;
154- }
155- default :
156- throw new IllegalArgumentException (
157- "Scheme is not supported: " + location .getUri ().getScheme ());
142+ final NettyChannelBuilder nettyChannelBuilder = NettyChannelBuilder .forTarget (location .getUri ().getHost ());
143+ var validSchemas = List .of (
144+ LocationSchemes .GRPC ,
145+ LocationSchemes .GRPC_INSECURE ,
146+ LocationSchemes .GRPC_TLS ,
147+ LocationSchemes .GRPC_DOMAIN_SOCKET
148+ );
149+ if (!validSchemas .contains (location .getUri ().getScheme ())) {
150+ throw new IllegalArgumentException (
151+ "Scheme is not supported: " + location .getUri ().getScheme ());
152+ }
153+
154+ if (location .getUri ().getScheme ().equals (LocationSchemes .GRPC_DOMAIN_SOCKET )) {
155+ setChannelTypeAndEventLoop (nettyChannelBuilder );
158156 }
159157
160158 if (LocationSchemes .GRPC_TLS .equals (location .getUri ().getScheme ())) {
0 commit comments