Stream worker updates
client.Workers.StreamUpdates(ctx, workerID) (*string, error)
GET/api/workers/{workerId}/stream
Subscribe to a worker using server-sent events.
Stream worker updates
package main
import (
"context"
"fmt"
"github.com/stainless-sdks/handinger-go"
"github.com/stainless-sdks/handinger-go/option"
)
func main() {
client := handinger.NewClient(
option.WithAPIKey("My API Key"),
)
stream := client.Workers.StreamUpdatesStreaming(context.TODO(), "t_org_123_w_01HZY2ZJQ8G7K42W2D7WF6V4GM")
for stream.Next() {
fmt.Printf("%+v\n", stream.Current())
}
err := stream.Err()
if err != nil {
panic(err.Error())
}
}