Versions in this module Expand all Collapse all v2 v2.1.0 Oct 2, 2023 Changes in this version + func Recent(t *Topic[T]) (_ T, _ bool) v2.0.0 Oct 2, 2023 Changes in this version + type Receiver struct + func (r *Receiver[T]) Unsubscribe() + type Topic struct + func New() *Topic[T] + func (t *Topic[T]) Close() error + func (t *Topic[T]) SendCh() chan<- T + func (t *Topic[T]) Subscribe(limit int) (*Receiver[T], <-chan T, error) Other modules containing this package github.com/bvkgo/topic
Go to main page