16 lines
355 B
Go
16 lines
355 B
Go
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
|
|
}
|