Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Option ¶
type Option[K comparable, T any] func(*Subscriber[K, T])
func WithID ¶
func WithID[K comparable, T any](id K) Option[K, T]
func WithSkip ¶
func WithSkip[K comparable, T any](skips ...skip[K, T]) Option[K, T]
type Subscriber ¶
type Subscriber[K comparable, T any] struct { ID K // contains filtered or unexported fields }
func New ¶
func New[K comparable, T any](opts ...Option[K, T]) *Subscriber[K, T]
func (*Subscriber[K, T]) Skip ¶
func (s *Subscriber[K, T]) Skip(v *T) bool
Source Files
Click to show internal directories.
Click to hide internal directories.