Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for PubSub (0.04 sec)

  1. 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)
  2. 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)
Back to top