- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 59 for notifiers (0.09 sec)
-
guava-tests/test/com/google/common/collect/FauxveridesTest.java
Set<MethodSignature> publicStaticMethods = new HashSet<>(); for (Method method : clazz.getDeclaredMethods()) { int modifiers = method.getModifiers(); if (isPublic(modifiers) && isStatic(modifiers)) { publicStaticMethods.add(new MethodSignature(method)); } } return publicStaticMethods; } /** [descendant, ancestor) */
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Jul 08 18:32:10 UTC 2025 - 9.4K bytes - Viewed (0) -
android/guava/src/com/google/common/cache/RemovalListener.java
* Object} if any key is acceptable * @author Charles Fry * @since 10.0 */ @GwtCompatible public interface RemovalListener<K, V> { /** * Notifies the listener that a removal occurred at some point in the past. * * <p>This does not always signify that the key is now absent from the cache, as it may have * already been re-added. */
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Sat Dec 21 03:10:51 UTC 2024 - 2K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/lock/Smb2OplockBreakNotification.java
import jcifs.internal.smb2.ServerMessageBlock2Response; import jcifs.internal.util.SMBUtil; import jcifs.util.Hexdump; /** * SMB2 Oplock Break notification message. This server-initiated message notifies the client * that an opportunistic lock must be broken due to conflicting access from another client. * * @author mbechler * */ public class Smb2OplockBreakNotification extends ServerMessageBlock2Response {Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 2.9K bytes - Viewed (0) -
src/main/java/jcifs/internal/witness/WitnessEventType.java
*/ package jcifs.internal.witness; /** * Enumeration of SMB Witness Event Types as defined in MS-SWN specification. * These events represent different types of cluster state changes that clients * can be notified about. */ public enum WitnessEventType { /** * Resource state changed - general resource state modification */ RESOURCE_CHANGE(1), /**Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 23 09:06:40 UTC 2025 - 2.5K bytes - Viewed (0) -
okhttp-sse/src/main/kotlin/okhttp3/sse/EventSource.kt
/** * Creates a new event source and immediately returns it. Creating an event source initiates an * asynchronous process to connect the socket. Once that succeeds or fails, `listener` will be * notified. The caller must cancel the returned event source when it is no longer in use. */ fun newEventSource( request: Request, listener: EventSourceListener, ): EventSource }Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Fri Oct 03 07:51:20 UTC 2025 - 1.4K bytes - Viewed (0) -
compat/maven-model/pom.xml
Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Wed Sep 17 10:01:14 UTC 2025 - 7.1K bytes - Viewed (0) -
cmd/event-notification.go
"github.com/minio/minio/internal/event" xhttp "github.com/minio/minio/internal/http" "github.com/minio/minio/internal/pubsub" "github.com/minio/pkg/v3/policy" ) // EventNotifier - notifies external systems about events in MinIO. type EventNotifier struct { sync.RWMutex targetList *event.TargetList bucketRulesMap map[string]event.RulesMap }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Jun 21 22:22:24 UTC 2024 - 7.7K bytes - Viewed (0) -
cmd/update-notifier_test.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "fmt" "strings" "testing" "time" "github.com/minio/minio/internal/color" ) // Tests update notifier string builder. func TestPrepareUpdateMessage(t *testing.T) { testCases := []struct { older time.Duration dlURL string expectedSubStr string }{ // Testcase index 0
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Mon Jul 31 15:36:19 UTC 2023 - 4.1K bytes - Viewed (0) -
src/test/java/jcifs/spnego/SpnegoConstantsTest.java
import java.util.Map; import java.util.regex.Pattern; import org.junit.jupiter.api.DisplayName; import org.junit.jupiter.api.Test; /** * Tests for SpnegoConstants interface. * Verifies constant values, modifiers, types, and structural properties. */ class SpnegoConstantsTest { // Simple OID format: numbers separated by dots (at least one dot) private static final Pattern OID_PATTERN = Pattern.compile("\\d+(?:\\.\\d+)+");Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 3.7K bytes - Viewed (0) -
okhttp/src/jvmMain/kotlin/okhttp3/internal/platform/Jdk8WithJettyBootPlatform.kt
* dependency on those interfaces. */ private class AlpnProvider( /** This peer's supported protocols. */ private val protocols: List<String>, ) : InvocationHandler { /** Set when remote peer notifies ALPN is unsupported. */ var unsupported: Boolean = false /** The protocol the server selected. */ var selected: String? = null @Throws(Throwable::class) override fun invoke(
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 6.1K bytes - Viewed (0)