Method
StreamSessionEvents
(
ctx context.Context,
id string,
query SessionEventQuery,
lastEventID string,
handler SSEHandler,
)
Source from the content-addressed store, hash-verified
| 3057 | } |
| 3058 | |
| 3059 | func (c *unixSocketClient) StreamSessionEvents( |
| 3060 | ctx context.Context, |
| 3061 | id string, |
| 3062 | query SessionEventQuery, |
| 3063 | lastEventID string, |
| 3064 | handler SSEHandler, |
| 3065 | ) error { |
| 3066 | path, err := c.sessionScopedPath(ctx, id, "/stream") |
| 3067 | if err != nil { |
| 3068 | return err |
| 3069 | } |
| 3070 | return c.doSSE( |
| 3071 | ctx, |
| 3072 | http.MethodGet, |
| 3073 | path, |
| 3074 | sessionEventValues(query), |
| 3075 | nil, |
| 3076 | lastEventID, |
| 3077 | handler, |
| 3078 | ) |
| 3079 | } |
| 3080 | |
| 3081 | func (c *unixSocketClient) SessionHistory( |
| 3082 | ctx context.Context, |