- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for PubSub (0.04 sec)
-
cmd/globals.go
// global Trace system to send HTTP request/response // and Storage/OS calls info to registered listeners. globalTrace = pubsub.New[madmin.TraceInfo, madmin.TraceType](8) // global Listen system to send S3 API events to registered listeners globalHTTPListen = pubsub.New[event.Event, pubsub.Mask](0) // global console system to send console logs to // registered listeners globalConsoleSys *HTTPConsoleLoggerSys
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Sep 03 18:23:41 UTC 2024 - 16.2K bytes - Viewed (1) -
android/guava-tests/test/com/google/common/collect/TreeRangeMapTest.java
3), rangeMap.asMapOfRanges()); assertThrows(IllegalArgumentException.class, () -> sub.put(Range.open(9, 12), 5)); RangeMap<Integer, Integer> subSub = sub.subRangeMap(Range.closedOpen(5, 5)); subSub.put(Range.closedOpen(5, 5), 6); // should be a no-op assertEquals( ImmutableMap.of( Range.open(3, 7), 1, Range.closed(7, 9),
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 17:27:14 UTC 2025 - 30K bytes - Viewed (0)