Table of Contents

Class SubmissionPublisher

Namespace
Java.Util.Concurrent
Assembly
MASES.JNet.dll
public class SubmissionPublisher : JVMBridgeBase<SubmissionPublisher>, IDynamicMetaObjectProvider, IJVMBridgeCore, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeDefinition
Inheritance
JVMBridgeBase
JVMBridgeBase<SubmissionPublisher>
SubmissionPublisher
Implements
IJVMBridgeCore
IJVMBridgeBaseStatic
IJVMBridgeBase
IJVMBridgeDefinition
Inherited Members
JVMBridgeBase<SubmissionPublisher>.IsAssignableFrom(IJavaType)
JVMBridgeBase<SubmissionPublisher>.IsAssignableFrom<T>()
JVMBridgeBase<SubmissionPublisher>.Execute<T>(params T[])
JVMBridgeBase<SubmissionPublisher>.DynBridgeClazz
JVMBridgeBase<SubmissionPublisher>.BridgeClazz
JVMBridgeBase.RuntimeClassNameOf<T>()
JVMBridgeBase.ClassNameOf<T>()
JVMBridgeBase.ClassOf<T>()
JVMBridgeBase.WrapsDirect<TNewClass>(IJavaObject)
JVMBridgeBase.Wraps<TNewClass>(IJavaObject)
JVMBridgeBase.Wraps<TNewClass, TReturn>(IJavaObject)
JVMBridgeBase.Wraps<TNewClass, TReturn, TConverter>(IJavaObject)
JVMBridgeBase.MonitorEnter()
JVMBridgeBase.MonitorExit()
JVMBridgeBase.IsInstanceOf(IJavaType)
JVMBridgeBase.IsInstanceOf<T>()
JVMBridgeBase.RuntimeIsInstanceOf<T>()
JVMBridgeBase.CastTo<TNewClass>()
JVMBridgeBase.CastDirect<TNewClass>()
JVMBridgeBase.Dispose()
JVMBridgeBase.ToString()
JVMBridgeBase.GetHashCode()
JVMBridgeBase.Notify()
JVMBridgeBase.NotifyAll()
JVMBridgeBase.Wait()
JVMBridgeBase.DynBridgeInstance
JVMBridgeBase.BridgeInstance
JVMBridgeBase.IsBridgeListener
Extension Methods

Constructors

SubmissionPublisher()

Default constructor: even if the corresponding Java class does not have one, it is mandatory for JCOBridge

public SubmissionPublisher()

SubmissionPublisher(Executor, int)

public SubmissionPublisher(Executor arg0, int arg1)

Parameters

arg0 Executor

Executor

arg1 int

int

SubmissionPublisher(Executor, int, BiConsumer)

public SubmissionPublisher(Executor arg0, int arg1, BiConsumer arg2)

Parameters

arg0 Executor

Executor

arg1 int

int

arg2 BiConsumer

BiConsumer

SubmissionPublisher(params object[])

Generic constructor: it is useful for JCOBridge when there is a derived class which needs to pass arguments to the highest JVMBridgeBase class

public SubmissionPublisher(params object[] args)

Parameters

args object[]

Properties

BridgeClassName

public override string BridgeClassName { get; }

Property Value

string

ClosedException

public Throwable ClosedException { get; }

Property Value

Throwable

Executor

public Executor Executor { get; }

Property Value

Executor

IsBridgeAbstract

public override bool IsBridgeAbstract { get; }

Property Value

bool

IsBridgeCloseable

public override bool IsBridgeCloseable { get; }

Property Value

bool

IsBridgeInterface

public override bool IsBridgeInterface { get; }

Property Value

bool

IsBridgeStatic

public override bool IsBridgeStatic { get; }

Property Value

bool

MaxBufferCapacity

public int MaxBufferCapacity { get; }

Property Value

int

NumberOfSubscribers

public int NumberOfSubscribers { get; }

Property Value

int

Subscribers

public List Subscribers { get; }

Property Value

List

Methods

Close()

public void Close()

CloseExceptionally(JVMBridgeException)

public void CloseExceptionally(JVMBridgeException arg0)

Parameters

arg0 JVMBridgeException

Throwable

Consume(Consumer)

public CompletableFuture Consume(Consumer arg0)

Parameters

arg0 Consumer

Consumer

Returns

CompletableFuture

CompletableFuture

EstimateMaximumLag()

public int EstimateMaximumLag()

Returns

int

int

EstimateMinimumDemand()

public long EstimateMinimumDemand()

Returns

long

long

HasSubscribers()

public bool HasSubscribers()

Returns

bool

bool

IsClosed()

public bool IsClosed()

Returns

bool

bool

IsSubscribed(Subscriber)

public bool IsSubscribed(Flow.Subscriber arg0)

Parameters

arg0 Flow.Subscriber

Flow.Subscriber

Returns

bool

bool

Offer(object, BiPredicate)

public int Offer(object arg0, BiPredicate arg1)

Parameters

arg0 object

object

arg1 BiPredicate

BiPredicate

Returns

int

int

Offer(object, long, TimeUnit, BiPredicate)

public int Offer(object arg0, long arg1, TimeUnit arg2, BiPredicate arg3)

Parameters

arg0 object

object

arg1 long

long

arg2 TimeUnit

TimeUnit

arg3 BiPredicate

BiPredicate

Returns

int

int

Submit(object)

public int Submit(object arg0)

Parameters

arg0 object

object

Returns

int

int

Subscribe(Subscriber)

public void Subscribe(Flow.Subscriber arg0)

Parameters

arg0 Flow.Subscriber

Flow.Subscriber

Operators

implicit operator AutoCloseable(SubmissionPublisher)

public static implicit operator AutoCloseable(SubmissionPublisher t)

Parameters

t SubmissionPublisher

Returns

AutoCloseable