Table of Contents

Class SubmissionPublisher<T>

Namespace
Java.Util.Concurrent
Assembly
MASES.JNet.dll
public class SubmissionPublisher<T> : JVMBridgeBase<SubmissionPublisher<T>>, IDynamicMetaObjectProvider, IJVMBridgeCore, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeDefinition

Type Parameters

T
Inheritance
JVMBridgeBase
JVMBridgeBase<SubmissionPublisher<T>>
SubmissionPublisher<T>
Implements
IJVMBridgeCore
IJVMBridgeBaseStatic
IJVMBridgeBase
IJVMBridgeDefinition
Inherited Members
JVMBridgeBase<SubmissionPublisher<T>>.IsAssignableFrom(IJavaType)
JVMBridgeBase<SubmissionPublisher<T>>.IsAssignableFrom<T>()
JVMBridgeBase<SubmissionPublisher<T>>.Execute<T>(params T[])
JVMBridgeBase<SubmissionPublisher<T>>.DynBridgeClazz
JVMBridgeBase<SubmissionPublisher<T>>.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<Arg0objectSuperT>(Consumer<Arg0objectSuperT>)

public CompletableFuture<Void> Consume<Arg0objectSuperT>(Consumer<Arg0objectSuperT> arg0) where Arg0objectSuperT : T

Parameters

arg0 Consumer<Arg0objectSuperT>

Consumer

Returns

CompletableFuture<Void>

CompletableFuture

Type Parameters

Arg0objectSuperT

T

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<Arg0objectSuperT>(Subscriber<Arg0objectSuperT>)

public bool IsSubscribed<Arg0objectSuperT>(Flow.Subscriber<Arg0objectSuperT> arg0) where Arg0objectSuperT : T

Parameters

arg0 Flow.Subscriber<Arg0objectSuperT>

Flow.Subscriber

Returns

bool

bool

Type Parameters

Arg0objectSuperT

T

Offer<Arg1objectSuperT>(T, BiPredicate<Subscriber<Arg1objectSuperT>, Arg1objectSuperT>)

public int Offer<Arg1objectSuperT>(T arg0, BiPredicate<Flow.Subscriber<Arg1objectSuperT>, Arg1objectSuperT> arg1) where Arg1objectSuperT : T

Parameters

arg0 T

T

arg1 BiPredicate<Flow.Subscriber<Arg1objectSuperT>, Arg1objectSuperT>

BiPredicate

Returns

int

int

Type Parameters

Arg1objectSuperT

T

Offer<Arg3objectSuperT>(T, long, TimeUnit, BiPredicate<Subscriber<Arg3objectSuperT>, Arg3objectSuperT>)

public int Offer<Arg3objectSuperT>(T arg0, long arg1, TimeUnit arg2, BiPredicate<Flow.Subscriber<Arg3objectSuperT>, Arg3objectSuperT> arg3) where Arg3objectSuperT : T

Parameters

arg0 T

T

arg1 long

long

arg2 TimeUnit

TimeUnit

arg3 BiPredicate<Flow.Subscriber<Arg3objectSuperT>, Arg3objectSuperT>

BiPredicate

Returns

int

int

Type Parameters

Arg3objectSuperT

T

Submit(T)

public int Submit(T arg0)

Parameters

arg0 T

T

Returns

int

int

Subscribe<Arg0objectSuperT>(Subscriber<Arg0objectSuperT>)

public void Subscribe<Arg0objectSuperT>(Flow.Subscriber<Arg0objectSuperT> arg0) where Arg0objectSuperT : T

Parameters

arg0 Flow.Subscriber<Arg0objectSuperT>

Flow.Subscriber

Type Parameters

Arg0objectSuperT

T

Operators

implicit operator AutoCloseable(SubmissionPublisher<T>)

public static implicit operator AutoCloseable(SubmissionPublisher<T> t)

Parameters

t SubmissionPublisher<T>

Returns

AutoCloseable

implicit operator SubmissionPublisher(SubmissionPublisher<T>)

public static implicit operator SubmissionPublisher(SubmissionPublisher<T> t)

Parameters

t SubmissionPublisher<T>

Returns

SubmissionPublisher