multiplex

Aug 2, 2024

Changes in this version

+ type ChatMultiplexer struct

+ BuildChatClient func(logger zerolog.Logger, provider twitch.AccountProvider, accountID string) Chat

+ func NewChatMultiplexer(logger zerolog.Logger, provider twitch.AccountProvider) *ChatMultiplexer

+ func (m *ChatMultiplexer) ListenAndServe(inbound <-chan InboundMessage) <-chan OutboundMessage

+ type EventMultiplexer struct

+ BuildEventSub func() EventSub

+ func NewEventMultiplexer(logger zerolog.Logger) *EventMultiplexer

+ func (e *EventMultiplexer) ListenAndServe(inbound <-chan EventSubInboundMessage) error

+ type EventSub interface

+ Connect func(inbound <-chan eventsub.InboundMessage) error

+ type EventSubInboundMessage struct

+ AccountID string

+ Msg eventsub.InboundMessage

Jul 24, 2024

Changes in this version

+ type Chat interface

+ ConnectWithRetry func(ctx context.Context, messages <-chan twitch.IRCer) (<-chan twitch.IRCer, <-chan error)

+ type DecrementTabCounter struct

+ type InboundMessage struct

+ AccountID string

+ Msg any

+ type IncrementTabCounter struct

+ type Multiplexer struct

+ BuildChatClient func(logger zerolog.Logger, provider twitch.AccountProvider, accountID string) Chat

+ func NewMultiplexer(logger zerolog.Logger, provider twitch.AccountProvider) *Multiplexer

+ func (m *Multiplexer) ListenAndServe(inbound <-chan InboundMessage) <-chan OutboundMessage

+ type OutboundMessage struct

+ Err error

+ ID string

+ Msg twitch.IRCer