IsClosed checks whether the topic is closed.

NewGoroutineClient instantiates an instance of GoroutineClient, which is used to listen on the listening port to receive subscription info.

NewGoroutinePooledClient instantiates an instance of GoroutinePooledClient, which is used to listen on the listening port to receive subscription info.

NewPollingClient instantiates a new polling client and listens on the listening port to get subscription.

NewUnboundedChan creates the unbounded chan.

NewUnboundedChanSize is like NewUnboundedChan but you can set initial capacity for In, Out, Buffer.

DefaultPort is default listening port.

DefaultMessageHandler is an implementation of MessageHandler, which is the default handler of IMessage.

GoroutineClient is an implementation of AbstractClient for streaming subscription.

GoroutinePooledClient is an implementation of AbstractClient for streaming subscription.

Message is the implementation of the IMessage.

PollingClient is a client for streaming subscription, which allows you to get subscription from the topicPoller.

RingBuffer is a ring buffer for common types.

SubscribeRequest is used for subscribing.

TopicPoller is used to take one or more subscription info for polling client.

UnboundedChan is an unbounded chan.

AbstractClient is the client interface for streaming subscription.

IMessage is the interface of subscription messages.

MessageBatchHandler is an interface which will help you to handle message.

MessageHandler is an interface which will help you to handle message.

T defines interface{}, and will be used for generic type after go 1.18 is released.