reactive

Documentation

Index

• func AwaitChannel[T any](channel <-chan T) tea.Cmd
• func ListManyFor[T any](sub *Subscription, in ...SubscriberMethod[T]) tea.Cmd
• func ListenFor[T any](sub *Subscription, in SubscriberMethod[T])
• func ReceiveOn[T any](sub *Subscription, channel chan T)
• type ChanMsg
• type Message
• type SubscriberMethod
• type Subscription
  • func NewSubscriber() *Subscription
  • func (r *Subscription) AwaitNextMsg() tea.Cmd

Functions

func AwaitChannel

func AwaitChannel[T any](channel <-chan T) tea.Cmd

func ListManyFor

func ListManyFor[T any](sub *Subscription, in ...SubscriberMethod[T]) tea.Cmd

func ListenFor

func ListenFor[T any](sub *Subscription, in SubscriberMethod[T])

func ReceiveOn

func ReceiveOn[T any](sub *Subscription, channel chan T)

Types

type ChanMsg

type ChanMsg[T any] struct {
	Source <-chan T
	Ok     bool
	Value  T
}

type Message

type Message struct {
	Msg tea.Msg
}

type SubscriberMethod

type SubscriberMethod[T any] func(fn func(T))

type Subscription

type Subscription struct {
	// contains filtered or unexported fields
}

func NewSubscriber

func NewSubscriber() *Subscription

func (*Subscription) AwaitNextMsg

func (r *Subscription) AwaitNextMsg() tea.Cmd