namespace Java.Util.Concurrent
{
    [Register("java/util/concurrent/Flow", ApiSince = 30, DoNotGenerateAcw = true)]
    public sealed class Flow : Object
    {
        [JavaTypeParameters(new[] { "T" })]
        [Register("java/util/concurrent/Flow$Subscriber", "", "Java.Util.Concurrent.Flow/ISubscriberInvoker", ApiSince = 30)]
        public interface ISubscriber : IJavaObject, IJavaPeerable, IDisposable
        {
            [Register("onError", "(Ljava/lang/Throwable;)V", "GetOnError_Ljava_lang_Throwable_Handler:Java.Util.Concurrent.Flow/ISubscriberInvoker, Mono.Android, Version=0.0.0.0, Culture=neutral, PublicKeyToken=null", ApiSince = 30)]
            void OnError(Throwable? throwable);
        }
    }
}