diff --git a/playground/go/main.go b/playground/go/main.go index 4afefe82..1e7e04cb 100644 --- a/playground/go/main.go +++ b/playground/go/main.go @@ -11,6 +11,7 @@ import ( func main() { app := arri.NewApp(http.DefaultServeMux, arri.AppOptions[arri.DefaultContext]{}, arri.CreateDefaultContext) + // register the EventStreamRpc handler arri.EventStreamRpc(&app, WatchMessages, arri.RpcOptions{}) app.Run(arri.RunOptions{}) }