package niri

import (
	"context"

	"git.tordarus.net/tordarus/channel"
)

func (c *Client) SubscribeEvents(ctx context.Context) (<-chan Event, error) {
	ch, err := subscribeSocket[*eventContainer](ctx, c.GetSocketPath(), asJsonReader("EventStream"))
	if err != nil {
		return nil, err
	}
	return channel.MapSuccessive(ch, (*eventContainer).event), nil
}