- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 859 for replay (0.2 sec)
-
android/guava-testlib/test/com/google/common/testing/EquivalenceTesterTest.java
equivalenceMock.expectHash(group1Item1, 1); equivalenceMock.expectHash(group1Item2, 1); equivalenceMock.expectHash(group2Item1, 2); equivalenceMock.expectHash(group2Item2, 2); equivalenceMock.replay(); tester .addEquivalenceGroup(group1Item1, group1Item2) .addEquivalenceGroup(group2Item1, group2Item2) .test(); } public void testTest_symmetric() {
Java - Registered: Fri Mar 22 12:43:11 GMT 2024 - Last Modified: Mon Oct 10 19:45:10 GMT 2022 - 8.3K bytes - Viewed (0) -
guava-testlib/test/com/google/common/testing/EquivalenceTesterTest.java
equivalenceMock.expectHash(group1Item1, 1); equivalenceMock.expectHash(group1Item2, 1); equivalenceMock.expectHash(group2Item1, 2); equivalenceMock.expectHash(group2Item2, 2); equivalenceMock.replay(); tester .addEquivalenceGroup(group1Item1, group1Item2) .addEquivalenceGroup(group2Item1, group2Item2) .test(); } public void testTest_symmetric() {
Java - Registered: Fri Mar 22 12:43:11 GMT 2024 - Last Modified: Mon Oct 10 19:45:10 GMT 2022 - 8.3K bytes - Viewed (0) -
src/main/java/jcifs/spnego/NegTokenInit.java
*/ @SuppressWarnings ( "javadoc" ) public class NegTokenInit extends SpnegoToken { public static final int DELEGATION = 0x80; public static final int MUTUAL_AUTHENTICATION = 0x40; public static final int REPLAY_DETECTION = 0x20; public static final int SEQUENCE_CHECKING = 0x10; public static final int ANONYMITY = 0x08; public static final int CONFIDENTIALITY = 0x04; public static final int INTEGRITY = 0x02;
Java - Registered: Sun Mar 24 00:10:09 GMT 2024 - Last Modified: Sun Oct 01 12:01:17 GMT 2023 - 7.9K bytes - Viewed (0) -
internal/logger/target/kafka/kafka.go
// Reading logCh must hold read lock on logChMu (to avoid read race) // Sending a value on logCh must hold read lock on logChMu (to avoid closing) logCh chan interface{} logChMu sync.RWMutex // store to persist and replay the logs to the target // to avoid missing events when the target is down. store store.Store[interface{}] storeCtxCancel context.CancelFunc initKafkaOnce once.Init initQueueStoreOnce once.Init
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 10.1K bytes - Viewed (1) -
docs/works_with_okhttp.md
* [OkHttp Profiler](https://plugins.jetbrains.com/plugin/11249-okhttp-profiler): An IntelliJ plugin for monitoring OkHttp calls. * [OkReplay](https://github.com/airbnb/okreplay): Record and replay OkHttp network interaction in your tests. * [okhttp-signpost](https://github.com/pakerfeldt/okhttp-signpost): OAuth signing with signpost and OkHttp.
Plain Text - Registered: Fri Mar 22 11:42:09 GMT 2024 - Last Modified: Wed Jun 08 18:15:23 GMT 2022 - 3.8K bytes - Viewed (0) -
internal/logger/target/http/http.go
// set this to '1'. batchSize int // If the first init fails, this starts a goroutine that // will attempt to establish the connection. revive sync.Once // store to persist and replay the logs to the target // to avoid missing events when the target is down. store store.Store[interface{}] storeCtxCancel context.CancelFunc initQueueStoreOnce once.Init config Config
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Thu Mar 07 20:17:46 GMT 2024 - 13K bytes - Viewed (0) -
src/main/java/jcifs/smb/Kerb5Context.java
if ( this.gssContext.getMutualAuthState() ) { contextFlags |= NegTokenInit.MUTUAL_AUTHENTICATION; } if ( this.gssContext.getReplayDetState() ) { contextFlags |= NegTokenInit.REPLAY_DETECTION; } if ( this.gssContext.getSequenceDetState() ) { contextFlags |= NegTokenInit.SEQUENCE_CHECKING; } if ( this.gssContext.getAnonymityState() ) {
Java - Registered: Sun Mar 24 00:10:09 GMT 2024 - Last Modified: Thu Aug 02 08:22:42 GMT 2018 - 13.9K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/ServerMessageBlock2.java
Java - Registered: Sun Mar 24 00:10:09 GMT 2024 - Last Modified: Sun Sep 30 10:47:31 GMT 2018 - 19.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Reader.kt
* Read a connection-level ping from the peer. `ack` indicates this is a reply. The data * in `payload1` and `payload2` opaque binary, and there are no rules on the content. */ fun ping( ack: Boolean, payload1: Int, payload2: Int, ) /** * The peer tells us to stop creating streams. It is safe to replay streams with
Plain Text - Registered: Fri Mar 22 11:42:09 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 19.9K bytes - Viewed (0) -
cmd/erasure-healing.go
// notFoundPartsErrs is ignored since // - delete marker does not have any parts dataBlocks := (len(errs) + 1) / 2 return validMeta, notFoundMetaErrs > dataBlocks } // TODO: It is possible to replay the object via just single // xl.meta file, considering quorum number of data-dirs are still // present on other drives. // // However this requires a bit of a rewrite, leave this up for // future work.
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Tue Feb 27 09:47:58 GMT 2024 - 32.6K bytes - Viewed (0)