org.jetlang.channels
Interface Subscribable<T>

All Superinterfaces:

Callback<T>

All Known Implementing Classes:

BaseSubscription, BatchSubscriber, ChannelSubscription, KeyedBatchSubscriber, LastSubscriber

public interface Subscribable<T>
extends Callback<T>

Interface to subscribe to events on producing thread(s). Implementations should be thread safe.

Method Summary

DisposingExecutor

getQueue()

Methods inherited from interface org.jetlang.core.Callback

onMessage

Method Detail

getQueue

DisposingExecutor getQueue()