public interface OutputChannelReader
| Modifier and Type | Method and Description |
|---|---|
SubscriptionHandle |
addChannelListener(ChannelListener listener)
Add a
ChannelListener implementation that data on this channel can be streamed to. |
void |
addSubscriber(org.reactivestreams.Subscriber<simudyne.core.channel.ChannelMessages.ChannelMessages> subscriber)
Add reactive stream subscriber implementation to data on this channel.
|
scala.concurrent.Future<simudyne.core.channel.ChannelImpl.ChannelComplete> |
complete()
Close this Channel so it cannot receive any new messages and clean up resources.
|
java.lang.String |
getId() |
ValueRecord |
getInitialValueRecord() |
java.util.Set<java.lang.String> |
getLabels() |
simudyne.core.schema.SchemaRecord |
getSchema() |
boolean |
isEnabled() |
void |
setEnabled(boolean isEnabled) |
java.lang.String getId()
java.util.Set<java.lang.String> getLabels()
simudyne.core.schema.SchemaRecord getSchema()
ValueRecord getInitialValueRecord()
SubscriptionHandle addChannelListener(ChannelListener listener)
ChannelListener implementation that data on this channel can be streamed to.listener - void addSubscriber(org.reactivestreams.Subscriber<simudyne.core.channel.ChannelMessages.ChannelMessages> subscriber)
void setEnabled(boolean isEnabled)
boolean isEnabled()
scala.concurrent.Future<simudyne.core.channel.ChannelImpl.ChannelComplete> complete()