multiplex

type Chat interface {
	ConnectWithRetry(ctx context.Context, messages <-chan twitch.IRCer) (<-chan twitch.IRCer, <-chan error)
}

type DecrementTabCounter struct{}

type InboundMessage struct {
	AccountID string
	Msg       any // Type of IncrementCounter, DecrementCounter, or twitch.IRCer
}

type IncrementTabCounter struct{}

type Multiplexer struct {
	BuildChatClient func(logger zerolog.Logger, provider twitch.AccountProvider, accountID string) Chat
	// contains filtered or unexported fields
}

type OutboundMessage struct {
	ID  string
	Msg twitch.IRCer
	Err error
}