Package org.mycore.webcli.flow
Class MCRCommandListProcessor
java.lang.Object
java.util.concurrent.SubmissionPublisher<com.google.gson.JsonObject>
org.mycore.webcli.flow.MCRCommandListProcessor
- All Implemented Interfaces:
AutoCloseable
,Flow.Processor<List<String>,
,com.google.gson.JsonObject> Flow.Publisher<com.google.gson.JsonObject>
,Flow.Subscriber<List<String>>
public class MCRCommandListProcessor
extends SubmissionPublisher<com.google.gson.JsonObject>
implements Flow.Processor<List<String>,com.google.gson.JsonObject>
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionvoid
close()
void
void
void
void
onSubscribe
(Flow.Subscription subscription) Methods inherited from class java.util.concurrent.SubmissionPublisher
closeExceptionally, consume, estimateMaximumLag, estimateMinimumDemand, getClosedException, getExecutor, getMaxBufferCapacity, getNumberOfSubscribers, getSubscribers, hasSubscribers, isClosed, isSubscribed, offer, offer, submit, subscribe
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface java.util.concurrent.Flow.Publisher
subscribe
-
Constructor Details
-
MCRCommandListProcessor
public MCRCommandListProcessor()
-
-
Method Details
-
onSubscribe
- Specified by:
onSubscribe
in interfaceFlow.Subscriber<List<String>>
-
onNext
- Specified by:
onNext
in interfaceFlow.Subscriber<List<String>>
-
onError
- Specified by:
onError
in interfaceFlow.Subscriber<List<String>>
-
onComplete
public void onComplete()- Specified by:
onComplete
in interfaceFlow.Subscriber<List<String>>
-
close
public void close()- Specified by:
close
in interfaceAutoCloseable
- Overrides:
close
in classSubmissionPublisher<com.google.gson.JsonObject>
-