@@ -180,13 +180,39 @@ void setInboundMessageSizeLarge() throws Exception {
180180 }
181181 }
182182
183+ @ Test
184+ void setGrpcCallOption () {
185+ Executor executor = Executors .newSingleThreadExecutor ();
186+ Deadline deadline = Deadline .after (2 , TimeUnit .SECONDS );
187+ String compressorName = "name" ;
188+
189+ GrpcCallOption grpcCallOption = new GrpcCallOption .Builder ().withExecutor (executor )
190+ .withMaxInboundMessageSize (1024 )
191+ .withMaxOutboundMessageSize (1024 )
192+ .withWaitForReady ()
193+ .withDeadline (deadline )
194+ .withCompressorName (compressorName )
195+ .build ();
196+
197+ QueryOptions options = new QueryOptions ("test" );
198+ options .setGrpcCallOption (grpcCallOption );
199+ Assertions .assertThat (options .grpcCallOption ()).isNotNull ();
200+ Assertions .assertThat (options .grpcCallOption ().getMaxInboundMessageSize ()).isEqualTo (1024 );
201+ Assertions .assertThat (options .grpcCallOption ().getMaxOutboundMessageSize ()).isEqualTo (1024 );
202+ Assertions .assertThat (options .grpcCallOption ().getExecutor ()).isEqualTo (executor );
203+ Assertions .assertThat (options .grpcCallOption ().getWaitForReady ()).isTrue ();
204+ Assertions .assertThat (options .grpcCallOption ().getCompressorName ()).isEqualTo (compressorName );
205+ Assertions .assertThat (options .grpcCallOption ().getDeadline ()).isEqualTo (deadline );
206+
207+ }
208+
183209 @ Test
184210 void grpcCallOptionDefaultOptions () {
185211 QueryOptions queryOptions = new QueryOptions ("test" );
186212 queryOptions .setGrpcCallOption (new GrpcCallOption .Builder ().build ());
187213 Assertions .assertThat (queryOptions .grpcCallOption ()).isNotNull ();
188214 Assertions .assertThat (queryOptions .grpcCallOption ()
189- .getMaxInboundMessageSize ()).isEqualTo (Integer .MAX_VALUE );
215+ .getMaxInboundMessageSize ()).isEqualTo (Integer .MAX_VALUE );
190216 }
191217
192218 @ Test
0 commit comments