Uses of Interface
com.oracle.coherence.concurrent.executor.Task.Subscription
Package
Description
Classes to allow submission of tasks to the grid for execution.
Task.Subscriber
implementations.-
Uses of Task.Subscription in com.oracle.coherence.concurrent.executor
Modifier and TypeMethodDescriptionvoid
Task.Subscriber.onSubscribe
(Task.Subscription<? extends T> subscription) Invoked prior to theTask.Subscriber
methodsTask.Subscriber.onComplete()
,Task.Subscriber.onError(Throwable)
andTask.Subscriber.onNext(Object)
being invoked for aTask.Subscription
to aTask.Coordinator
. -
Uses of Task.Subscription in com.oracle.coherence.concurrent.executor.subscribers
Modifier and TypeFieldDescriptionprotected Task.Subscription
<? extends T> RecordingSubscriber.m_subscription
TheTask.Subscription
.protected Task.Subscription
SystemOutSubscriber.m_subscription
TheTask.Subscription
for theTask.Subscriber
.Modifier and TypeMethodDescriptionvoid
RecordingSubscriber.onSubscribe
(Task.Subscription<? extends T> subscription) void
SystemOutSubscriber.onSubscribe
(Task.Subscription subscription)