JoinSubscriptions joins multiple subscriptions to be able to track them as one entity and collectively cancel them or consume any errors from them.

NewSubscription runs a producer function as a subscription in a new goroutine.

Resubscribe calls fn repeatedly to keep a subscription established.

ResubscribeErr calls fn repeatedly to keep a subscription established.

ErrMuxClosed is returned when Posting on a closed TypeMux.

Feed implements one-to-many subscriptions where the carrier of events is a channel.

FeedOf implements one-to-many subscriptions where the carrier of events is a channel.

SubscriptionScope provides a facility to unsubscribe multiple subscriptions at once.

A TypeMux dispatches events to registered receivers.

TypeMuxEvent is a time-tagged notification pushed to subscribers.

TypeMuxSubscription is a subscription established through TypeMux.

Subscription represents a stream of events.

A ResubscribeErrFunc attempts to establish a subscription.

A ResubscribeFunc attempts to establish a subscription.