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

Now returns the current absolute monotonic time.

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.

System implements Clock using the system clock.

ChanTimer is a cancellable event created by NewTimer.

The Clock interface makes it possible to replace the monotonic system clock with a simulated clock.

Subscription represents a stream of events.

Timer is a cancellable event created by AfterFunc.

AbsTime represents absolute monotonic time.

A ResubscribeFunc attempts to establish a subscription.