- Sort Score
- Result 10 results
- Languages All
Results 341 - 350 of 458 for Runnable (0.67 sec)
-
android/guava-tests/test/com/google/common/io/IoTestCase.java
if (testDir != null) { return testDir; } URL testFileUrl = IoTestCase.class.getResource("testdata/i18n.txt"); if (testFileUrl == null) { throw new RuntimeException("unable to locate testdata directory"); } if (testFileUrl.getProtocol().equals("file")) { try { File testFile = new File(testFileUrl.toURI());
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 5.6K bytes - Viewed (0) -
internal/event/target/webhook.go
queueStore = store.NewQueueStore[event.Event](queueDir, args.QueueLimit, event.StoreExtension) if err := queueStore.Open(); err != nil { cancel() return nil, fmt.Errorf("unable to initialize the queue store of Webhook `%s`: %w", id, err) } } target := &WebhookTarget{ id: event.TargetID{ID: id, Name: "webhook"}, args: args, loggerOnce: loggerOnce,
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 8.8K bytes - Viewed (0) -
cmd/bucket-lifecycle_test.go
} } } func TestObjectIsRemote(t *testing.T) { fi := newFileInfo("object", 8, 8) fi.Erasure.Index = 1 if !fi.IsValid() { t.Fatalf("unable to get xl meta") } testCases := []struct { meta map[string]string remote bool }{ { // restore in progress meta: map[string]string{
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue May 31 09:57:57 UTC 2022 - 7K bytes - Viewed (0) -
internal/event/target/redis.go
queueStore = store.NewQueueStore[event.Event](queueDir, args.QueueLimit, event.StoreExtension) if err := queueStore.Open(); err != nil { return nil, fmt.Errorf("unable to initialize the queue store of Redis `%s`: %w", id, err) } } pool := &redis.Pool{ MaxIdle: 3, IdleTimeout: 2 * 60 * time.Second, Dial: func() (redis.Conn, error) {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Mar 30 00:56:02 UTC 2025 - 9.1K bytes - Viewed (0) -
tests/test_tutorial/test_body/test_tutorial001.py
Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Sat Dec 27 18:19:10 UTC 2025 - 10.6K bytes - Viewed (0) -
internal/event/target/nsq.go
queueStore = store.NewQueueStore[event.Event](queueDir, args.QueueLimit, event.StoreExtension) if err := queueStore.Open(); err != nil { return nil, fmt.Errorf("unable to initialize the queue store of NSQ `%s`: %w", id, err) } } target := &NSQTarget{ id: event.TargetID{ID: id, Name: "nsq"}, args: args, loggerOnce: loggerOnce,
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Mar 30 00:56:02 UTC 2025 - 7.1K bytes - Viewed (0) -
api/maven-api-di/src/main/java/org/apache/maven/di/tool/DiIndexProcessor.java
} existingContent = contentBuilder.toString(); } } catch (IOException e) { logMessage(Diagnostic.Kind.NOTE, "Unable to read existing file. Proceeding with empty content."); } Set<String> allClasses = new TreeSet<>(existingClasses); // Using TreeSet for natural ordering allClasses.addAll(processedClasses);Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Thu Apr 03 13:33:59 UTC 2025 - 7.8K bytes - Viewed (0) -
CODE_OF_CONDUCT.md
real-time medium. 2. If this fails, get a third party (e.g. a mutual friend, and/or someone with background on the issue, but not involved in the conflict) to intercede. 3. If you are still unable to resolve the conflict, and you believe it rises to harassment or another code of conduct violation, report it. ## Reporting Violations
Registered: Tue Dec 30 12:39:10 UTC 2025 - Last Modified: Fri Feb 05 18:43:16 UTC 2021 - 5.2K bytes - Viewed (0) -
internal/event/target/amqp.go
queueStore = store.NewQueueStore[event.Event](queueDir, args.QueueLimit, event.StoreExtension) if err := queueStore.Open(); err != nil { return nil, fmt.Errorf("unable to initialize the queue store of AMQP `%s`: %w", id, err) } } target := &AMQPTarget{ id: event.TargetID{ID: id, Name: "amqp"}, args: args, loggerOnce: loggerOnce,
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Thu Aug 21 04:25:07 UTC 2025 - 10K bytes - Viewed (0) -
docs/de/docs/tutorial/path-params.md
Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Wed Dec 17 20:41:43 UTC 2025 - 10.5K bytes - Viewed (0)