(ctx context.Context, data string)
| 529 | } |
| 530 | |
| 531 | func (ws *WshServer) EventUnsubCommand(ctx context.Context, data string) error { |
| 532 | rpcSource := wshutil.GetRpcSourceFromContext(ctx) |
| 533 | if rpcSource == "" { |
| 534 | return fmt.Errorf("no rpc source set") |
| 535 | } |
| 536 | wps.Broker.Unsubscribe(rpcSource, data) |
| 537 | return nil |
| 538 | } |
| 539 | |
| 540 | func (ws *WshServer) EventUnsubAllCommand(ctx context.Context) error { |
| 541 | rpcSource := wshutil.GetRpcSourceFromContext(ctx) |
nothing calls this directly
no test coverage detected