public class CloseableChannel<T> extends Object implements org.jetlang.channels.Channel<T>
| Modifier and Type | Class and Description |
|---|---|
static class |
CloseableChannel.Group |
| Constructor and Description |
|---|
CloseableChannel(org.jetlang.channels.Channel<T> target) |
| Modifier and Type | Method and Description |
|---|---|
void |
close() |
boolean |
isClosed() |
void |
publish(T t) |
org.jetlang.core.Disposable |
subscribe(org.jetlang.core.DisposingExecutor disposingExecutor,
org.jetlang.core.Callback<T> tCallback) |
org.jetlang.core.Disposable |
subscribe(org.jetlang.channels.Subscribable<T> tSubscribable) |
int |
subscriptionCount() |
static <T> CloseableChannel<T> |
wrap(org.jetlang.channels.Channel<T> channel) |
public CloseableChannel(org.jetlang.channels.Channel<T> target)
public void publish(T t)
publish in interface org.jetlang.channels.Publisher<T>public org.jetlang.core.Disposable subscribe(org.jetlang.core.DisposingExecutor disposingExecutor,
org.jetlang.core.Callback<T> tCallback)
subscribe in interface org.jetlang.channels.Subscriber<T>public org.jetlang.core.Disposable subscribe(org.jetlang.channels.Subscribable<T> tSubscribable)
subscribe in interface org.jetlang.channels.Subscriber<T>public int subscriptionCount()
public boolean isClosed()
public void close()
public static <T> CloseableChannel<T> wrap(org.jetlang.channels.Channel<T> channel)
Copyright © 2016. All Rights Reserved.