- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 614 for constructs (0.36 sec)
-
okhttp/src/main/kotlin/okhttp3/Interceptor.kt
* * return chain.proceed(chain.request()) * } * ``` */ fun interface Interceptor { @Throws(IOException::class) fun intercept(chain: Chain): Response companion object { /** * Constructs an interceptor for a lambda. This compact syntax is most useful for inline * interceptors. * * ```kotlin * val interceptor = Interceptor { chain: Interceptor.Chain ->
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 3.5K bytes - Viewed (0) -
internal/logger/target/kafka/kafka_scram_client_contrib.go
// each authentication attempt. type XDGSCRAMClient struct { *scram.Client *scram.ClientConversation scram.HashGeneratorFcn } // Begin constructs a SCRAM client component based on a given hash.Hash // factory receiver. This constructor will normalize the username, password // and authzID via the SASLprep algorithm, as recommended by RFC-5802. If // SASLprep fails, the method returns an error.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Nov 09 04:04:01 UTC 2023 - 3.3K bytes - Viewed (0) -
istioctl/pkg/xds/client.go
} err = adscConn.Send(dr) if err != nil { return nil, err } response, err := adscConn.WaitVersion(opts.Timeout, dr.TypeUrl, "") return response, err } // DialOptions constructs gRPC dial options from command line configuration func DialOptions(opts clioptions.CentralControlPlaneOptions, ns, serviceAccount string, kubeClient kube.CLIClient, ) ([]grpc.DialOption, error) { ctx := context.TODO()
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Tue Dec 19 22:42:42 UTC 2023 - 3.7K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/SmbFile.java
this.shareAccess = shareAccess; } /** * Constructs an SmbFile representing a resource on an SMB network such * as a file or directory from a <tt>URL</tt> object. * * @param url The URL of the target resource */ public SmbFile( URL url ) { this( url, new NtlmPasswordAuthentication( url.getUserInfo() )); } /** * Constructs an SmbFile representing a resource on an SMB network such
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Mon Mar 13 12:00:57 UTC 2023 - 107.9K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/collect/testing/AbstractTester.java
import junit.framework.TestCase; import org.checkerframework.checker.nullness.qual.Nullable; /** * This abstract base class for testers allows the framework to inject needed information after * JUnit constructs the instances. * * <p>This class is emulated in GWT. * * @param <G> the type of the test generator required by this tester. An instance of G should
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Oct 28 21:41:47 UTC 2024 - 3.4K bytes - Viewed (0) -
guava-testlib/src/com/google/common/collect/testing/AbstractTester.java
import junit.framework.TestCase; import org.checkerframework.checker.nullness.qual.Nullable; /** * This abstract base class for testers allows the framework to inject needed information after * JUnit constructs the instances. * * <p>This class is emulated in GWT. * * @param <G> the type of the test generator required by this tester. An instance of G should
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Oct 28 21:41:47 UTC 2024 - 3.4K bytes - Viewed (0) -
internal/dsync/dsync-client_test.go
) // ReconnectRESTClient is a wrapper type for rest.Client which provides reconnect on first failure. type ReconnectRESTClient struct { u *url.URL rest *rest.Client } // newClient constructs a ReconnectRESTClient object with addr and endpoint initialized. // It _doesn't_ connect to the remote endpoint. See Call method to see when the // connect happens. func newClient(endpoint string) NetLocker {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Jan 20 17:36:09 UTC 2022 - 4.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/hash/AbstractNonStreamingHashFunctionTest.java
import java.util.List; import java.util.Random; import junit.framework.TestCase; /** Tests for AbstractNonStreamingHashFunction. */ public class AbstractNonStreamingHashFunctionTest extends TestCase { /** * Constructs two trivial HashFunctions (output := input), one streaming and one non-streaming, * and checks that their results are identical, no matter which newHasher version we used. */ public void testExhaustive() {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Dec 04 17:37:03 UTC 2017 - 4.4K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java
} @Override protected void tearDown() throws Exception { // Make sure we have no waiting threads. latch.countDown(); } /** Constructs a listenable future with a value available after the latch has counted down. */ protected abstract <V> ListenableFuture<V> createListenableFuture( V value, @Nullable Exception except, CountDownLatch waitOn);
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Sep 06 18:30:30 UTC 2023 - 6K bytes - Viewed (0) -
android/guava/src/com/google/common/graph/StandardMutableNetwork.java
* @param <E> Edge parameter type */ @ElementTypesAreNonnullByDefault final class StandardMutableNetwork<N, E> extends StandardNetwork<N, E> implements MutableNetwork<N, E> { /** Constructs a mutable graph with the properties specified in {@code builder}. */ StandardMutableNetwork(NetworkBuilder<? super N, ? super E> builder) { super(builder); } @Override @CanIgnoreReturnValue
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Apr 26 17:43:39 UTC 2021 - 5.7K bytes - Viewed (0)