- Sort Score
- Num 10 results
- Language All
Results 401 - 410 of 649 for set_op (0.13 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
okhttp/src/jvmTest/kotlin/okhttp3/internal/http/ThreadInterruptTest.kt
val platform = PlatformRule() @RegisterExtension val clientTestRule = OkHttpClientTestRule() private lateinit var server: MockWebServer private lateinit var client: OkHttpClient @BeforeEach fun setUp() { // Sockets on some platforms can have large buffers that mean writes do not block when // required. These socket factories explicitly set the buffer sizes on sockets created. server = MockWebServer()
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Nov 04 18:33:48 GMT 2025 - 6.4K bytes - Click Count (0) -
internal/event/target/nsq.go
} // Close - closes underneath connections to NSQD server. func (target *NSQTarget) Close() (err error) { close(target.quitCh) if target.producer != nil { // this blocks until complete: target.producer.Stop() } return nil } func (target *NSQTarget) init() error { return target.initOnce.Do(target.initNSQ) } func (target *NSQTarget) initNSQ() error { args := target.args
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Mar 30 00:56:02 GMT 2025 - 7.1K bytes - Click Count (0) -
src/test/java/jcifs/internal/fscc/FileRenameInformation2Test.java
/** * Test class for FileRenameInformation2 */ @DisplayName("FileRenameInformation2 Tests") class FileRenameInformation2Test { private FileRenameInformation2 fileRenameInfo; @BeforeEach void setUp() { fileRenameInfo = new FileRenameInformation2(); } @Test @DisplayName("Test default constructor") void testDefaultConstructor() { assertNotNull(fileRenameInfo); }Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 11.3K bytes - Click Count (0) -
compat/maven-compat/src/test/java/org/apache/maven/repository/LegacyRepositorySystemTest.java
} @Inject DefaultMetadataSource defaultMetadataSource; @Inject SwitchableMetadataSource switchableMetadataSource; @BeforeEach void setup() throws CycleDetectedInComponentGraphException { switchableMetadataSource.setDelegate(defaultMetadataSource); }Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Tue Dec 16 13:41:14 GMT 2025 - 11.1K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/sso/saml/SamlAuthenticatorTest.java
import org.junit.jupiter.api.Test; import org.junit.jupiter.api.TestInfo; public class SamlAuthenticatorTest extends UnitFessTestCase { @Override protected void setUp(TestInfo testInfo) throws Exception { super.setUp(testInfo); } @Override protected void tearDown(TestInfo testInfo) throws Exception { super.tearDown(testInfo); } /**Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Wed Jan 14 14:29:07 GMT 2026 - 18.4K bytes - Click Count (0) -
src/test/java/jcifs/internal/smb1/SMB1SigningDigestTest.java
@Mock private ServerMessageBlock mockResponse; @Mock private TimeZone mockTimeZone; private byte[] testMacSigningKey; @BeforeEach void setUp() { MockitoAnnotations.openMocks(this); testMacSigningKey = new byte[] { 0x01, 0x02, 0x03, 0x04, 0x05, 0x06, 0x07, 0x08, 0x09, 0x0A, 0x0B, 0x0C, 0x0D, 0x0E, 0x0F, 0x10 }; } @TestCreated: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 18.1K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/helper/CrawlingConfigHelperTest.java
public class CrawlingConfigHelperTest extends UnitFessTestCase { private CrawlingConfigHelper crawlingConfigHelper; @Override protected void setUp(TestInfo testInfo) throws Exception { super.setUp(testInfo); final File propFile = File.createTempFile("system", ".properties"); propFile.deleteOnExit(); FileUtil.writeBytes(propFile.getAbsolutePath(), "".getBytes());Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Mar 13 23:01:26 GMT 2026 - 35.3K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/SocketChannelTest.kt
.addTrustedCertificate(heldCertificate.certificate) .build() } private var acceptedHostName: String? = null @StartStop private val server = MockWebServer() @BeforeEach fun setUp() { // Test designed for Conscrypt and JSSE platform.assumeNotBouncyCastle() } @Test fun testHttp(socketMode: SocketMode = burstValues(Channel, Standard)) { testConnection(socketMode) }
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sat Nov 01 12:18:11 GMT 2025 - 7.9K bytes - Click Count (0) -
guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java
*/ @GwtIncompatible public abstract class AbstractListenableFutureTest extends TestCase { protected CountDownLatch latch; protected ListenableFuture<Boolean> future; @Override protected void setUp() throws Exception { // Create a latch and a future that waits on the latch. latch = new CountDownLatch(1); future = createListenableFuture(Boolean.TRUE, null, latch); } @OverrideCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Jul 11 18:52:30 GMT 2025 - 6.1K bytes - Click Count (0) -
src/test/java/jcifs/smb/compression/DefaultCompressionServiceTest.java
*/ public class DefaultCompressionServiceTest { private DefaultCompressionService compressionService; private byte[] testData; private byte[] largeTestData; @BeforeEach public void setUp() { compressionService = new DefaultCompressionService(); // Create test data with patterns that should compress well testData = generateTestData(1024); largeTestData = generateTestData(8192);Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sun Aug 31 08:00:57 GMT 2025 - 9.1K bytes - Click Count (0)