- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 23 for newProxy (0.54 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/SimpleTimeLimiterTest.java
service = SimpleTimeLimiter.create(executor); } public void testNewProxy_goodMethodWithEnoughTime() throws Exception { SampleImpl target = new SampleImpl(DELAY_MS); Sample proxy = service.newProxy(target, Sample.class, ENOUGH_MS, MILLISECONDS); Stopwatch stopwatch = Stopwatch.createStarted(); String result = proxy.sleepThenReturnInput("x"); assertThat(result).isEqualTo("x");
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 9.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/SimpleTimeLimiterTest.java
service = SimpleTimeLimiter.create(executor); } public void testNewProxy_goodMethodWithEnoughTime() throws Exception { SampleImpl target = new SampleImpl(DELAY_MS); Sample proxy = service.newProxy(target, Sample.class, ENOUGH_MS, MILLISECONDS); Stopwatch stopwatch = Stopwatch.createStarted(); String result = proxy.sleepThenReturnInput("x"); assertThat(result).isEqualTo("x");
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 9.5K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/reflect/ReflectionTest.java
} public void testNewProxy() throws Exception { Runnable runnable = Reflection.newProxy(Runnable.class, X_RETURNER); assertEquals("x", runnable.toString()); } public void testNewProxyCantWorkOnAClass() throws Exception { assertThrows( IllegalArgumentException.class, () -> Reflection.newProxy(Object.class, X_RETURNER)); } private static final InvocationHandler X_RETURNER =
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 2.7K bytes - Viewed (0) -
guava-testlib/src/com/google/common/testing/ForwardingWrapperTester.java
Class<T> interfaceType, Method method, Function<? super T, ? extends T> wrapperFunction) { RuntimeException exception = new RuntimeException(); T proxy = Reflection.newProxy( interfaceType, new AbstractInvocationHandler() { @Override protected Object handleInvocation(Object p, Method m, @Nullable Object[] args)
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 08 17:31:55 UTC 2024 - 9.1K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/FakeTimeLimiter.java
@J2ktIncompatible @GwtIncompatible @ElementTypesAreNonnullByDefault public final class FakeTimeLimiter implements TimeLimiter { @CanIgnoreReturnValue // TODO(kak): consider removing this @Override public <T> T newProxy( T target, Class<T> interfaceType, long timeoutDuration, TimeUnit timeoutUnit) { checkNotNull(target); checkNotNull(interfaceType); checkNotNull(timeoutUnit); return target; // ha ha }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Dec 14 20:35:03 UTC 2023 - 3.5K bytes - Viewed (0) -
guava-testlib/src/com/google/common/testing/DummyProxy.java
/** * Returns a new proxy for {@code interfaceType}. Proxies of the same interface are equal to each * other if the {@link DummyProxy} instance that created the proxies are equal. */ final <T> T newProxy(TypeToken<T> interfaceType) { Set<Class<?>> interfaceClasses = Sets.newLinkedHashSet(); interfaceClasses.addAll(interfaceType.getTypes().interfaces().rawTypes());
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 08 17:31:55 UTC 2024 - 3.9K bytes - Viewed (0) -
pkg/envoy/proxy.go
Concurrency int32 // For unit testing, in combination with NoEnvoy prevents agent.Run from blocking TestOnly bool AgentIsRoot bool } // NewProxy creates an instance of the proxy control commands func NewProxy(cfg ProxyConfig) Proxy { // inject tracing flag for higher levels var args []string logLevel, componentLogs := splitComponentLog(cfg.LogLevel) if logLevel != "" {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 05 10:02:56 UTC 2024 - 6.9K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/testing/ForwardingWrapperTester.java
Class<T> interfaceType, Method method, Function<? super T, ? extends T> wrapperFunction) { RuntimeException exception = new RuntimeException(); T proxy = Reflection.newProxy( interfaceType, new AbstractInvocationHandler() { @Override protected Object handleInvocation(Object p, Method m, @Nullable Object[] args)
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 08 17:31:55 UTC 2024 - 9.1K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/FakeTimeLimiter.java
@J2ktIncompatible @GwtIncompatible @ElementTypesAreNonnullByDefault public final class FakeTimeLimiter implements TimeLimiter { @CanIgnoreReturnValue // TODO(kak): consider removing this @Override public <T> T newProxy( T target, Class<T> interfaceType, long timeoutDuration, TimeUnit timeoutUnit) { checkNotNull(target); checkNotNull(interfaceType); checkNotNull(timeoutUnit); return target; // ha ha }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Dec 14 20:35:03 UTC 2023 - 3.5K bytes - Viewed (0) -
pkg/envoy/proxy_test.go
DrainDuration: proxyConfig.DrainDuration, Concurrency: 8, } test := &envoy{ ProxyConfig: cfg, extraArgs: []string{"-l", "trace", "--component-log-level", "misc:error"}, } testProxy := NewProxy(cfg) if !reflect.DeepEqual(testProxy, test) { t.Errorf("unexpected struct got\n%v\nwant\n%v", testProxy, test) } got := test.args("test.json", "testdata/bootstrap.json") want := []string{ "-c", "test.json",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 09 11:45:51 UTC 2024 - 3.2K bytes - Viewed (0)