Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 65 for subscribed (0.1 sec)

  1. .github/ISSUE_TEMPLATE/bug_report.md

    ---
    name: Bug report
    about: Create a report to help us improve
    title: ''
    labels: community, triage
    assignees: ''
    
    ---
    
    ## NOTE
    If this case is urgent, please subscribe to [Subnet](https://min.io/pricing) so that our 24/7 support team may help you faster.
    
    <!--- Provide a general summary of the issue in the Title above -->
    
    ## Expected Behavior
    <!--- If you're describing a bug, tell us what should happen -->
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 20 17:37:40 UTC 2022
    - 1.7K bytes
    - Viewed (0)
  2. cmd/background-heal-ops.go

    }
    
    func activeListeners() int {
    	// Bucket notification and http trace are not costly, it is okay to ignore them
    	// while counting the number of concurrent connections
    	return int(globalHTTPListen.Subscribers()) + int(globalTrace.Subscribers())
    }
    
    func waitForLowIO(maxIO int, maxWait time.Duration, currentIO func() int) {
    	// No need to wait run at full speed.
    	if maxIO <= 0 {
    		return
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  3. docs/en/docs/js/custom.js

                ul.append(li)
            })
        }
    
        setupTermynal();
        showRandomAnnouncement('announce-left', 5000)
        showRandomAnnouncement('announce-right', 10000)
    }
    document$.subscribe(() => {
        main()
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Aug 06 04:48:30 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  4. docs/bucket/notifications/README.md

          if c.NatsConn() != nil {
           c.NatsConn().Close()
          }
          _ = c.Close()
         }))
         if stanConnection != nil {
          subscribe()
         }
    
        }
       }
    
      }()
     }))
    
     // Subscribe to subject
     subscribe()
    
     // Keep the connection alive
     runtime.Goexit()
    }
    
    ```
    
    ```
    go run nats.go
    2017/07/07 11:47:40 Connected
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 84K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/eventbus/AsyncEventBus.java

       *     down the executor after the last event has been posted to this event bus.
       * @param subscriberExceptionHandler Handler used to handle exceptions thrown from subscribers.
       *     See {@link SubscriberExceptionHandler} for more information.
       * @since 16.0
       */
      public AsyncEventBus(Executor executor, SubscriberExceptionHandler subscriberExceptionHandler) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Apr 22 13:05:46 UTC 2021
    - 2.5K bytes
    - Viewed (0)
  6. cmd/http-tracer.go

    		reqStartTime := time.Now().UTC()
    		h.ServeHTTP(respRecorder, r)
    		reqEndTime := time.Now().UTC()
    
    		if globalTrace.NumSubscribers(madmin.TraceS3|madmin.TraceInternal) == 0 {
    			// no subscribers nothing to trace.
    			return
    		}
    
    		tt := madmin.TraceInternal
    		if strings.HasPrefix(tc.FuncName, "s3.") {
    			tt = madmin.TraceS3
    		}
    
    		// Calculate input body size with headers
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 17:13:00 UTC 2024
    - 6K bytes
    - Viewed (0)
  7. docs/en/overrides/main.html

        </div>
        <div class="item">
          <a class="announce-link" href="https://fastapi.tiangolo.com/newsletter/">
            <span class="twemoji">
              {% include ".icons/material/email.svg" %}
            </span> Subscribe to the <strong>FastAPI and friends</strong> newsletter 🎉
          </a>
        </div>
        <div class="item">
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Thu Oct 31 09:13:26 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  8. cmd/listen-notification-handlers.go

    			case <-ctx.Done():
    				grid.PutByteBuffer(buf.Bytes())
    				return
    			}
    		}
    	}()
    	peers, _ := newPeerRestClients(globalEndpoints)
    	err := globalHTTPListen.Subscribe(mask, localCh, ctx.Done(), func(ev event.Event) bool {
    		if ev.S3.Bucket.Name != "" && bucketName != "" {
    			if ev.S3.Bucket.Name != bucketName {
    				return false
    			}
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 6K bytes
    - Viewed (0)
  9. docs/en/docs/help-fastapi.md

    Or would you like to get help with **FastAPI**?
    
    There are very simple ways to help (several involve just one or two clicks).
    
    And there are several ways to get help too.
    
    ## Subscribe to the newsletter
    
    You can subscribe to the (infrequent) [**FastAPI and friends** newsletter](newsletter.md){.internal-link target=_blank} to stay updated about:
    
    * News about FastAPI and friends 🚀
    * Guides 📝
    * Features ✨
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Thu Aug 15 23:30:12 UTC 2024
    - 13.7K bytes
    - Viewed (0)
  10. README.md

    - **Community Slack**: [Join our Slack Channel](https://gradle.org/slack-invite) for real-time discussions, with specialized channels like `#github-integrations` for integration topics.
    - **Newsletter**: Subscribe to the [Gradle Newsletter](https://newsletter.gradle.org) for news, tutorials, and community highlights.
    
    > **Quick Tip**: New contributors to Gradle projects are encouraged to ask questions in the Slack `#community-support` channel.
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Fri Nov 01 05:30:25 UTC 2024
    - 8K bytes
    - Viewed (0)
Back to top