- Sort Score
- Result 10 results
- Languages All
Results 241 - 250 of 410 for Callbacks (0.04 sec)
-
android/guava-tests/test/com/google/common/eventbus/EventBusTest.java
@SuppressWarnings("AnonymousToLambda") public void testRegistrationWithBridgeMethod() { AtomicInteger calls = new AtomicInteger(); bus.register( new Callback<String>() { @Subscribe @Override public void call(String s) { calls.incrementAndGet(); } }); bus.post("hello");
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Jul 16 17:42:14 UTC 2025 - 11.3K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/util/AccessResultCallback.java
* governing permissions and limitations under the License. */ package org.codelibs.fess.crawler.util; import org.codelibs.fess.crawler.entity.AccessResult; /** * A callback interface for processing access results. * * @param <RESULT> the type of access result that extends {@link AccessResult} */ public interface AccessResultCallback<RESULT extends AccessResult<?>> { /**
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sun Jul 06 02:13:03 UTC 2025 - 1.2K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/FutureCallback.java
import com.google.common.annotations.GwtCompatible; import java.util.concurrent.ExecutionException; import java.util.concurrent.Future; import org.jspecify.annotations.Nullable; /** * A callback for accepting the results of a {@link java.util.concurrent.Future} computation * asynchronously. * * <p>To attach to a {@link ListenableFuture} use {@link Futures#addCallback}. * * @author Anthony Zana
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 1.5K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/util/MemoryUtilTest.java
nestedMap.put("outer", Maps.map("inner", "value").$()); assertEquals(183L, MemoryUtil.sizeOf(nestedMap)); } public void test_sizeOf_customObjects() { // Test fallback case for custom objects (should return 16L) assertEquals(16L, MemoryUtil.sizeOf(new Object())); assertEquals(16L, MemoryUtil.sizeOf(new CustomTestObject()));
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sat Jul 12 07:34:10 UTC 2025 - 11.8K bytes - Viewed (0) -
src/test/java/jcifs/smb/SmbResourceLocatorImplTest.java
assertEquals("share/", b.getName()); // host when no path/share SmbResourceLocatorImpl c = locator("smb://server/"); assertEquals("server/", c.getName()); // root fallback SmbResourceLocatorImpl d = locator("smb:///"); assertEquals("smb://", d.getName()); } @Test @DisplayName("Parent URL is computed correctly") void testGetParent() {
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 17.6K bytes - Viewed (0) -
guava/src/com/google/common/io/Files.java
} /** * Streams lines from a {@link File}, stopping when our callback returns false, or we have read * all of the lines. * * @param file the file to read from * @param charset the charset used to decode the input stream; see {@link StandardCharsets} for * helpful predefined constants * @param callback the {@link LineProcessor} to use to handle the lines
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 17:27:14 UTC 2025 - 32.9K bytes - Viewed (0) -
cmd/is-dir-empty_linux.go
"syscall" ) // Returns true if no error and there is no object or prefix inside this directory func isDirEmpty(dirname string, legacy bool) bool { if legacy { // On filesystems such as btrfs, nfs this is not true, so fallback // to performing readdir() instead. entries, err := readDirN(dirname, 1) if err != nil { return false } return len(entries) == 0 } var stat syscall.Stat_t
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Apr 05 15:17:08 UTC 2024 - 1.4K bytes - Viewed (0) -
okhttp-dnsoverhttps/src/main/kotlin/okhttp3/dnsoverhttps/DnsOverHttps.kt
*/ package okhttp3.dnsoverhttps import java.io.IOException import java.net.InetAddress import java.net.UnknownHostException import java.util.concurrent.CountDownLatch import okhttp3.Call import okhttp3.Callback import okhttp3.Dns import okhttp3.HttpUrl import okhttp3.MediaType import okhttp3.MediaType.Companion.toMediaType import okhttp3.OkHttpClient import okhttp3.Protocol import okhttp3.Request
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat May 10 11:15:14 UTC 2025 - 8.6K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/ResponseBody.kt
* may ultimately cause the application to slow down or crash. * * Both this class and [Response] implement [Closeable]. Closing a response simply * closes its response body. If you invoke [Call.execute] or implement [Callback.onResponse] you * must close this body by calling any of the following methods: * * * `Response.close()` * * `Response.body().close()` * * `Response.body().source().close()`
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Tue May 27 14:51:25 UTC 2025 - 11.6K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/rdma/tcp/TcpMemoryRegion.java
import java.util.concurrent.atomic.AtomicInteger; import jcifs.internal.smb2.rdma.RdmaAccess; import jcifs.internal.smb2.rdma.RdmaMemoryRegion; /** * TCP memory region implementation. * * For TCP fallback, memory regions are just wrappers around * ByteBuffers since no real RDMA registration is needed. */ public class TcpMemoryRegion extends RdmaMemoryRegion {
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 23 05:11:12 UTC 2025 - 2.1K bytes - Viewed (0)