Java/java/util/concurrent/SubmissionPublisher.fz

# Fuzion interface to instance members of Java instance class 'java.util.concurrent.SubmissionPublisher'
#
# !!!!!!  DO NOT EDIT, GENERATED CODE !!!!!!
#
# This code was generated automatically using the fzjava tool V0.087 called 
# as follows:
#
#   ./build/bin/fzjava java.base -to=build/modules/java.base -verbose=0
#
public Java.java.util.concurrent.SubmissionPublisher(redef forbidden void) ref : Java.java.lang.Object(forbidden), fuzion.java.Java_Object(forbidden) is

  # call Java instance method 'public void java.util.concurrent.SubmissionPublisher.close()':
  #
  public close unit =>
    fuzion.java.call_virtual (unit) "java.util.concurrent.SubmissionPublisher" "close" "()V" SubmissionPublisher.this []

  # call Java instance method 'public void java.util.concurrent.SubmissionPublisher.closeExceptionally(java.lang.Throwable)':
  #
  public closeExceptionally_Ljava_7_lang_7_Throwable_s_(arg0 Java.java.lang.Throwable) unit =>
    fuzion.java.call_virtual (unit) "java.util.concurrent.SubmissionPublisher" "closeExceptionally" "(Ljava/lang/Throwable;)V" SubmissionPublisher.this [(Java.java.util.concurrent.SubmissionPublisher.closeExceptionally_Ljava_7_lang_7_Throwable_s_.this.arg0)]

  # call Java instance method 'public java.util.concurrent.CompletableFuture java.util.concurrent.SubmissionPublisher.consume(java.util.function.Consumer)':
  #
  public consume_Ljava_7_util_7_function_7_Consumer_s_(arg0 Java.java.util.function.Consumer) Java.java.util.concurrent.CompletableFuture =>
    fuzion.java.call_virtual (Java.java.util.concurrent.CompletableFuture) "java.util.concurrent.SubmissionPublisher" "consume" "(Ljava/util/function/Consumer;)Ljava/util/concurrent/CompletableFuture;" SubmissionPublisher.this [(Java.java.util.concurrent.SubmissionPublisher.consume_Ljava_7_util_7_function_7_Consumer_s_.this.arg0)]

  # call Java instance method 'public int java.util.concurrent.SubmissionPublisher.estimateMaximumLag()':
  #
  public estimateMaximumLag i32 =>
    fuzion.java.call_virtual (i32) "java.util.concurrent.SubmissionPublisher" "estimateMaximumLag" "()I" SubmissionPublisher.this []

  # call Java instance method 'public long java.util.concurrent.SubmissionPublisher.estimateMinimumDemand()':
  #
  public estimateMinimumDemand i64 =>
    fuzion.java.call_virtual (i64) "java.util.concurrent.SubmissionPublisher" "estimateMinimumDemand" "()J" SubmissionPublisher.this []

  # call Java instance method 'public java.lang.Throwable java.util.concurrent.SubmissionPublisher.getClosedException()':
  #
  public getClosedException Java.java.lang.Throwable =>
    fuzion.java.call_virtual (Java.java.lang.Throwable) "java.util.concurrent.SubmissionPublisher" "getClosedException" "()Ljava/lang/Throwable;" SubmissionPublisher.this []

  # call Java instance method 'public java.util.concurrent.Executor java.util.concurrent.SubmissionPublisher.getExecutor()':
  #
  public getExecutor Java.java.util.concurrent.Executor =>
    fuzion.java.call_virtual (Java.java.util.concurrent.Executor) "java.util.concurrent.SubmissionPublisher" "getExecutor" "()Ljava/util/concurrent/Executor;" SubmissionPublisher.this []

  # call Java instance method 'public int java.util.concurrent.SubmissionPublisher.getMaxBufferCapacity()':
  #
  public getMaxBufferCapacity i32 =>
    fuzion.java.call_virtual (i32) "java.util.concurrent.SubmissionPublisher" "getMaxBufferCapacity" "()I" SubmissionPublisher.this []

  # call Java instance method 'public int java.util.concurrent.SubmissionPublisher.getNumberOfSubscribers()':
  #
  public getNumberOfSubscribers i32 =>
    fuzion.java.call_virtual (i32) "java.util.concurrent.SubmissionPublisher" "getNumberOfSubscribers" "()I" SubmissionPublisher.this []

  # call Java instance method 'public java.util.List java.util.concurrent.SubmissionPublisher.getSubscribers()':
  #
  public getSubscribers Java.java.util.List =>
    fuzion.java.call_virtual (Java.java.util.List) "java.util.concurrent.SubmissionPublisher" "getSubscribers" "()Ljava/util/List;" SubmissionPublisher.this []

  # call Java instance method 'public boolean java.util.concurrent.SubmissionPublisher.hasSubscribers()':
  #
  public hasSubscribers bool =>
    fuzion.java.call_virtual (bool) "java.util.concurrent.SubmissionPublisher" "hasSubscribers" "()Z" SubmissionPublisher.this []

  # call Java instance method 'public boolean java.util.concurrent.SubmissionPublisher.isClosed()':
  #
  public isClosed bool =>
    fuzion.java.call_virtual (bool) "java.util.concurrent.SubmissionPublisher" "isClosed" "()Z" SubmissionPublisher.this []

  # call Java instance method 'public boolean java.util.concurrent.SubmissionPublisher.isSubscribed(java.util.concurrent.Flow$Subscriber)':
  #
  public isSubscribed_Ljava_7_util_7_concurrent_7_Flow_S_Subscriber_s_(arg0 Java.java.util.concurrent.Flow_S_Subscriber) bool =>
    fuzion.java.call_virtual (bool) "java.util.concurrent.SubmissionPublisher" "isSubscribed" "(Ljava/util/concurrent/Flow\$Subscriber;)Z" SubmissionPublisher.this [(Java.java.util.concurrent.SubmissionPublisher.isSubscribed_Ljava_7_util_7_concurrent_7_Flow_S_Subscriber_s_.this.arg0)]

  # call Java instance method 'public int java.util.concurrent.SubmissionPublisher.offer(java.lang.Object,long,java.util.concurrent.TimeUnit,java.util.function.BiPredicate)':
  #
  public offer_Ljava_7_lang_7_Object_s_JLjava_7_util_7_concurrent_7_TimeUnit_s_Ljava_7_util_7_function_7_BiPredicate_s_(arg0 Java.java.lang.Object, arg1 i64, arg2 Java.java.util.concurrent.TimeUnit, arg3 Java.java.util.function.BiPredicate) i32 =>
    fuzion.java.call_virtual (i32) "java.util.concurrent.SubmissionPublisher" "offer" "(Ljava/lang/Object;JLjava/util/concurrent/TimeUnit;Ljava/util/function/BiPredicate;)I" SubmissionPublisher.this [(Java.java.util.concurrent.SubmissionPublisher.offer_Ljava_7_lang_7_Object_s_JLjava_7_util_7_concurrent_7_TimeUnit_s_Ljava_7_util_7_function_7_BiPredicate_s_.this.arg0); (fuzion.java.i64_to_java_object Java.java.util.concurrent.SubmissionPublisher.offer_Ljava_7_lang_7_Object_s_JLjava_7_util_7_concurrent_7_TimeUnit_s_Ljava_7_util_7_function_7_BiPredicate_s_.this.arg1); (Java.java.util.concurrent.SubmissionPublisher.offer_Ljava_7_lang_7_Object_s_JLjava_7_util_7_concurrent_7_TimeUnit_s_Ljava_7_util_7_function_7_BiPredicate_s_.this.arg2); (Java.java.util.concurrent.SubmissionPublisher.offer_Ljava_7_lang_7_Object_s_JLjava_7_util_7_concurrent_7_TimeUnit_s_Ljava_7_util_7_function_7_BiPredicate_s_.this.arg3)]

  # call Java instance method 'public int java.util.concurrent.SubmissionPublisher.offer(java.lang.Object,java.util.function.BiPredicate)':
  #
  public offer_Ljava_7_lang_7_Object_s_Ljava_7_util_7_function_7_BiPredicate_s_(arg0 Java.java.lang.Object, arg1 Java.java.util.function.BiPredicate) i32 =>
    fuzion.java.call_virtual (i32) "java.util.concurrent.SubmissionPublisher" "offer" "(Ljava/lang/Object;Ljava/util/function/BiPredicate;)I" SubmissionPublisher.this [(Java.java.util.concurrent.SubmissionPublisher.offer_Ljava_7_lang_7_Object_s_Ljava_7_util_7_function_7_BiPredicate_s_.this.arg0); (Java.java.util.concurrent.SubmissionPublisher.offer_Ljava_7_lang_7_Object_s_Ljava_7_util_7_function_7_BiPredicate_s_.this.arg1)]

  # call Java instance method 'public int java.util.concurrent.SubmissionPublisher.submit(java.lang.Object)':
  #
  public submit_Ljava_7_lang_7_Object_s_(arg0 Java.java.lang.Object) i32 =>
    fuzion.java.call_virtual (i32) "java.util.concurrent.SubmissionPublisher" "submit" "(Ljava/lang/Object;)I" SubmissionPublisher.this [(Java.java.util.concurrent.SubmissionPublisher.submit_Ljava_7_lang_7_Object_s_.this.arg0)]

  # call Java instance method 'public void java.util.concurrent.SubmissionPublisher.subscribe(java.util.concurrent.Flow$Subscriber)':
  #
  public subscribe_Ljava_7_util_7_concurrent_7_Flow_S_Subscriber_s_(arg0 Java.java.util.concurrent.Flow_S_Subscriber) unit =>
    fuzion.java.call_virtual (unit) "java.util.concurrent.SubmissionPublisher" "subscribe" "(Ljava/util/concurrent/Flow\$Subscriber;)V" SubmissionPublisher.this [(Java.java.util.concurrent.SubmissionPublisher.subscribe_Ljava_7_util_7_concurrent_7_Flow_S_Subscriber_s_.this.arg0)]

  # short-hand to call Java method 'public void java.util.concurrent.SubmissionPublisher.closeExceptionally(java.lang.Throwable)':
  #
  public closeExceptionally(arg0 Java.java.lang.Throwable) (unit) =>
    closeExceptionally_Ljava_7_lang_7_Throwable_s_ Java.java.util.concurrent.SubmissionPublisher.closeExceptionally.this.arg0

  # short-hand to call Java method 'public java.util.concurrent.CompletableFuture java.util.concurrent.SubmissionPublisher.consume(java.util.function.Consumer)':
  #
  public consume(arg0 Java.java.util.function.Consumer) (Java.java.util.concurrent.CompletableFuture) =>
    consume_Ljava_7_util_7_function_7_Consumer_s_ Java.java.util.concurrent.SubmissionPublisher.consume.this.arg0

  # short-hand to call Java method 'public boolean java.util.concurrent.SubmissionPublisher.isSubscribed(java.util.concurrent.Flow$Subscriber)':
  #
  public isSubscribed(arg0 Java.java.util.concurrent.Flow_S_Subscriber) (bool) =>
    isSubscribed_Ljava_7_util_7_concurrent_7_Flow_S_Subscriber_s_ Java.java.util.concurrent.SubmissionPublisher.isSubscribed.this.arg0

  # short-hand to call Java method 'public int java.util.concurrent.SubmissionPublisher.offer(java.lang.Object,java.util.function.BiPredicate)':
  #
  public offer(arg0 Java.java.lang.Object, arg1 Java.java.util.function.BiPredicate) (i32) =>
    offer_Ljava_7_lang_7_Object_s_Ljava_7_util_7_function_7_BiPredicate_s_ Java.java.util.concurrent.SubmissionPublisher.offer.this.arg0 Java.java.util.concurrent.SubmissionPublisher.offer.this.arg1

  # short-hand to call Java method 'public int java.util.concurrent.SubmissionPublisher.offer(java.lang.Object,long,java.util.concurrent.TimeUnit,java.util.function.BiPredicate)':
  #
  public offer(arg0 Java.java.lang.Object, arg1 i64, arg2 Java.java.util.concurrent.TimeUnit, arg3 Java.java.util.function.BiPredicate) (i32) =>
    offer_Ljava_7_lang_7_Object_s_JLjava_7_util_7_concurrent_7_TimeUnit_s_Ljava_7_util_7_function_7_BiPredicate_s_ Java.java.util.concurrent.SubmissionPublisher.offer.this.arg0 Java.java.util.concurrent.SubmissionPublisher.offer.this.arg1 Java.java.util.concurrent.SubmissionPublisher.offer.this.arg2 Java.java.util.concurrent.SubmissionPublisher.offer.this.arg3

  # short-hand to call Java method 'public int java.util.concurrent.SubmissionPublisher.submit(java.lang.Object)':
  #
  public submit(arg0 Java.java.lang.Object) (i32) =>
    submit_Ljava_7_lang_7_Object_s_ Java.java.util.concurrent.SubmissionPublisher.submit.this.arg0

  # short-hand to call Java method 'public void java.util.concurrent.SubmissionPublisher.subscribe(java.util.concurrent.Flow$Subscriber)':
  #
  public subscribe(arg0 Java.java.util.concurrent.Flow_S_Subscriber) (unit) =>
    subscribe_Ljava_7_util_7_concurrent_7_Flow_S_Subscriber_s_ Java.java.util.concurrent.SubmissionPublisher.subscribe.this.arg0