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

Resubscribe calls fn repeatedly to keep a subscription established.

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

SubscriptionScope provides a facility to unsubscribe multiple subscriptions at once.

Subscription represents a stream of events.

A ResubscribeFunc attempts to establish a subscription.