- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 34 for notified_ (0.18 sec)
-
guava/src/com/google/common/cache/RemovalListener.java
* Object} if any key is acceptable * @author Charles Fry * @since 10.0 */ @GwtCompatible @FunctionalInterface @ElementTypesAreNonnullByDefault 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 Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Jun 15 18:00:07 UTC 2021 - 2K 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 Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 31 15:36:19 UTC 2023 - 4.1K bytes - Viewed (0) -
okhttp/src/main/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 Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 6K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt
nanos: Long, ) { taskRunner.assertThreadHoldsLock() check(waitingCoordinatorTask == null) if (nanos == 0L) return // Yield until notified, interrupted, or the duration elapses. val waitUntil = nanoTime + nanos val self = currentTask waitingCoordinatorTask = self waitingCoordinatorNotified = false
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Apr 29 00:33:04 UTC 2024 - 12.6K bytes - Viewed (0) -
compat/maven-model/pom.xml
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 6.9K 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 Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jun 21 22:22:24 UTC 2024 - 7.7K bytes - Viewed (0) -
docs/fr/docs/help-fastapi.md
* Entendre quand je fais des annonces ou que je lance de nouveaux outils. * <a href="https://www.linkedin.com/in/tiangolo/" class="external-link" target="_blank">Vous connectez à moi sur **LinkedIn**</a>. * Etre notifié quand je fais des annonces ou que je lance de nouveaux outils (bien que j'utilise plus souvent Twitter 🤷♂).
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Mon Jul 29 23:35:07 UTC 2024 - 5.7K bytes - Viewed (0) -
cmd/notification.go
reqInfo := (&logger.ReqInfo{}).AppendTags("peerAddress", nErr.Host.String()) if nErr.Err != nil { peersLogOnceIf(logger.SetReqInfo(ctx, reqInfo), nErr.Err, nErr.Host.String()) } } } // DeleteUploadID notifies all the MinIO nodes to remove the // given uploadID from cache func (sys *NotificationSys) DeleteUploadID(ctx context.Context, uploadID string) { ng := WithNPeers(len(sys.peerClients))
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 09 16:58:30 UTC 2024 - 46.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/OkHttpClient.kt
* assume that connectivity has been lost. When this happens on a web socket the connection is * canceled and its listener is [notified][WebSocketListener.onFailure]. When it happens on an * HTTP/2 connection the connection is closed and any calls it is carrying * [will fail with an IOException][java.io.IOException]. *
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Apr 06 04:21:33 UTC 2024 - 52K bytes - Viewed (0) -
docs/en/docs/help-fastapi.md
If you select "Watching" instead of "Releases only" you will receive notifications when someone creates a new issue or question. You can also specify that you only want to be notified about new issues, or discussions, or PRs, etc. Then you can try and help them solve those questions. ## Ask Questions
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Thu Aug 15 23:30:12 UTC 2024 - 13.7K bytes - Viewed (0)