(ctx context.Context, data wshrpc.CommandWaitForRouteData)
| 497 | } |
| 498 | |
| 499 | func (ws *WshServer) WaitForRouteCommand(ctx context.Context, data wshrpc.CommandWaitForRouteData) (bool, error) { |
| 500 | waitCtx, cancelFn := context.WithTimeout(ctx, time.Duration(data.WaitMs)*time.Millisecond) |
| 501 | defer cancelFn() |
| 502 | err := wshutil.DefaultRouter.WaitForRegister(waitCtx, data.RouteId) |
| 503 | return err == nil, nil |
| 504 | } |
| 505 | |
| 506 | func (ws *WshServer) EventRecvCommand(ctx context.Context, data wps.WaveEvent) error { |
| 507 | return nil |
nothing calls this directly
no test coverage detected