語言

SubmissionPublisher.Submit(Object) 方法

定義

透過非同步呼叫該 Flow.Subscriber#onNext(Object) onNext 方法,在任何訂閱者資源無法使用時,將指定項目發佈給每位現有訂閱者,且不間斷地封鎖。

[Android.Runtime.Register("submit", "(Ljava/lang/Object;)I", "GetSubmit_Ljava_lang_Object_Handler", ApiSince=33)]
public virtual int Submit(Java.Lang.Object? item);
[<Android.Runtime.Register("submit", "(Ljava/lang/Object;)I", "GetSubmit_Ljava_lang_Object_Handler", ApiSince=33)>]
abstract member Submit : Java.Lang.Object -> int
override this.Submit : Java.Lang.Object -> int

參數

item
Object

要發佈的(非空)項目

傳回

訂閱者間估計的最大延遲

屬性

備註

透過非同步呼叫該 Flow.Subscriber#onNext(Object) onNext 方法,在任何訂閱者資源無法使用時,將指定項目發佈給每位現有訂閱者,且不間斷地封鎖。 此方法會回傳所有現有訂閱者的最大延遲估計值(提交但尚未消費的項目數量)。 如果有訂閱者,這個值至少是一(考慮本已提交項目),否則為零。

若該發布者的執行者在嘗試非同步通知訂閱者時拋出 RejectedExecutionException(或其他 RuntimeException 或錯誤),則該例外會被重新拋出,此時並非所有訂閱者都已收到此項目。

Java 文件 java.util.concurrent.SubmissionPublisher.submit(T)。

本頁部分內容為基於 Open Source Project 所創建與分享的作品,並依授權條款所描述的使用進行修改。

適用於