| /external/grpc-grpc-java/core/src/jmh/java/io/grpc/ |
| D | CallOptionsBenchmark.java | 59 allOpts = allOpts.withOption(customOptions.get(i), "value"); in setUp()
73 public CallOptions withOption() { in withOption() method in CallOptionsBenchmark
76 opts = opts.withOption(customOptions.get(i), "value"); in withOption()
90 opts = opts.withOption(shuffledCustomOptions.get(i), "value2"); in withOptionDuplicates()
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/ |
| D | CallOptionsTest.java | 59 .withOption(OPTION_1, "value1")
61 .withOption(OPTION_2, "value2")
182 CallOptions opts = CallOptions.DEFAULT.withOption(OPTION_1, "v1"); in withCustomOption()
188 CallOptions opts = CallOptions.DEFAULT.withOption(OPTION_1, "v1").withOption(OPTION_1, "v2"); in withCustomOptionLastOneWins()
194 CallOptions opts = CallOptions.DEFAULT.withOption(OPTION_1, "v1").withOption(OPTION_2, "v2"); in withMultipleCustomOption()
|
| D | ClientInterceptorsTest.java | 399 CallOptions callOptions = CallOptions.DEFAULT.withOption(customOption, "value"); in customOptionAccessible()
|
| /external/grpc-grpc-java/stub/src/main/java/io/grpc/stub/ |
| D | AbstractStub.java | 175 public final <T> S withOption(CallOptions.Key<T> key, T value) { in withOption() method in AbstractStub
176 return build(channel, callOptions.withOption(key, value)); in withOption()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | ServiceConfigInterceptor.java | 314 .withOption(RETRY_POLICY_KEY, new ImmediateRetryPolicyProvider()) in interceptCall()
315 .withOption(HEDGING_POLICY_KEY, new ImmediateHedgingPolicyProvider()); in interceptCall()
355 .withOption(RETRY_POLICY_KEY, new DelayedRetryPolicyProvider()) in interceptCall()
356 .withOption(HEDGING_POLICY_KEY, new DelayedHedgingPolicyProvider()); in interceptCall()
|
| /external/grpc-grpc-java/examples/android/clientcache/app/src/test/java/io/grpc/clientcacheexample/ |
| D | SafeMethodCachingInterceptorTest.java | 168 CallOptions.DEFAULT.withOption(SafeMethodCachingInterceptor.NO_CACHE_CALL_OPTION, true), in requestWithNoCacheOptionSkipsCache()
184 CallOptions.DEFAULT.withOption( in requestWithOnlyIfCachedOption_unavailableIfNotInCache()
205 CallOptions.DEFAULT.withOption( in requestWithOnlyIfCachedOption_usesCache()
219 .withOption(SafeMethodCachingInterceptor.NO_CACHE_CALL_OPTION, true) in requestWithNoCacheAndOnlyIfCached_fails()
220 .withOption(SafeMethodCachingInterceptor.ONLY_IF_CACHED_CALL_OPTION, true), in requestWithNoCacheAndOnlyIfCached_fails()
|
| /external/grpc-grpc-java/cronet/src/main/java/io/grpc/cronet/ |
| D | CronetCallOptions.java | 59 return callOptions.withOption( in withAnnotation()
|
| /external/grpc-grpc-java/examples/android/clientcache/app/src/main/java/io/grpc/clientcacheexample/ |
| D | ClientCacheExampleActivity.java | 125 callOptions.withOption(SafeMethodCachingInterceptor.NO_CACHE_CALL_OPTION, true); in doInBackground()
129 callOptions.withOption( in doInBackground()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/ |
| D | CallOptions.java | 308 public <T> CallOptions withOption(Key<T> key, T value) { in withOption() method in CallOptions
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | DelayedClientTransportTest.java | 288 CallOptions failFastCallOptions = CallOptions.DEFAULT.withOption(SHARD_ID, 1); in reprocessSemantics()
289 CallOptions waitForReadyCallOptions = CallOptions.DEFAULT.withOption(SHARD_ID, 2) in reprocessSemantics()
|
| D | CensusModulesTest.java | 106 CallOptions.DEFAULT.withOption(CUSTOM_OPTION, "customvalue");
|
| /external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/ |
| D | NettyChannelBuilder.java | 151 public <T> NettyChannelBuilder withOption(ChannelOption<T> option, T value) { in withOption() method in NettyChannelBuilder
|
| /external/grpc-grpc-java/cronet/src/test/java/io/grpc/cronet/ |
| D | CronetClientStreamTest.java | 590 CallOptions.DEFAULT.withOption(CronetCallOptions.CRONET_ANNOTATION_KEY, annotation), in addCronetRequestAnnotation_deprecated()
|