multiplex

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

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

type DecrementTabCounter struct{}

type EventMultiplexer struct {
	BuildEventSub func() EventSub
	// contains filtered or unexported fields
}

type EventSub interface {
	Connect(inbound <-chan eventsub.InboundMessage) error
}

type EventSubInboundMessage struct {
	AccountID string
	Msg       eventsub.InboundMessage
}

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

type IncrementTabCounter struct{}

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