async

type AsyncNotifier interface {
	// Publish sends an event to all subscribers of the given channel.
	Publish(ctx context.Context, channel string, event *Event) error
	// Close releases resources held by the notifier.
	Close() error
}

type ConnectionAcceptor interface {
	// AcceptConnection upgrades an HTTP request to a persistent connection
	// and registers it under the given channel and memberID.
	// The connection is managed internally; events published to the channel
	// will be delivered to this connection.
	AcceptConnection(w http.ResponseWriter, r *http.Request, channel, memberID string) error
}

type Event struct {
	Type string          `json:"type"`
	Data json.RawMessage `json:"data,omitempty"`
}