java.lang.Object
com.github.mizosoft.methanol.testing.SubmittablePublisher<T>
- All Implemented Interfaces:
AutoCloseable
,Flow.Publisher<T>
public final class SubmittablePublisher<T>
extends Object
implements Flow.Publisher<T>, AutoCloseable
A
Flow.Publisher<T>
that emits submitted items. The publisher is similar to SubmissionPublisher
but doesn't require the executor to operate
concurrently and has an unbounded buffer.-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionvoid
close()
void
void
void
subscribe
(Flow.Subscriber<? super T> subscriber)
-
Constructor Details
-
SubmittablePublisher
-
-
Method Details
-
subscribe
- Specified by:
subscribe
in interfaceFlow.Publisher<T>
-
firstSubscription
-
submit
-
submitAll
-
close
public void close()- Specified by:
close
in interfaceAutoCloseable
-