Package query implements the custom query format used to filter event subscriptions in Tendermint.

BufferCapacity allows you to specify capacity for publisher's queue.

NewServer returns a new server.

ErrAlreadySubscribed is returned when a client tries to subscribe twice or more using the same query.

ErrServerStopped is returned when attempting to publish or subscribe to a server that has been stopped.

ErrSubscriptionNotFound is returned when a client tries to unsubscribe from not existing subscription.

ErrTerminated is returned by Next when the subscription was terminated by the publisher.

ErrUnsubscribed is returned by Next when the client has unsubscribed.

Message glues data and events together.

Server allows clients to subscribe/unsubscribe for messages, publishing messages with or without events, and manages internal state.

SubscribeArgs are the parameters to create a new subscription.

A Subscription represents a client subscription for a particular query.

UnsubscribeArgs are the parameters to remove a subscription.

Option sets a parameter for the server.