(ctx context.Context)
| 538 | } |
| 539 | |
| 540 | func (ws *WshServer) EventUnsubAllCommand(ctx context.Context) error { |
| 541 | rpcSource := wshutil.GetRpcSourceFromContext(ctx) |
| 542 | if rpcSource == "" { |
| 543 | return fmt.Errorf("no rpc source set") |
| 544 | } |
| 545 | wps.Broker.UnsubscribeAll(rpcSource) |
| 546 | return nil |
| 547 | } |
| 548 | |
| 549 | func (ws *WshServer) EventReadHistoryCommand(ctx context.Context, data wshrpc.CommandEventReadHistoryData) ([]*wps.WaveEvent, error) { |
| 550 | events := wps.Broker.ReadEventHistory(data.Event, data.Scope, data.MaxItems) |
nothing calls this directly
no test coverage detected