(ctx context.Context, data wshrpc.CommandJobStartStreamData)
| 115 | } |
| 116 | |
| 117 | func (msc *MainServerConn) JobStartStreamCommand(ctx context.Context, data wshrpc.CommandJobStartStreamData) error { |
| 118 | if !msc.PeerAuthenticated.Load() { |
| 119 | return fmt.Errorf("not authenticated") |
| 120 | } |
| 121 | return WshCmdJobManager.StartStream(msc) |
| 122 | } |
| 123 | |
| 124 | func (msc *MainServerConn) JobInputCommand(ctx context.Context, data wshrpc.CommandJobInputData) error { |
| 125 | if !msc.PeerAuthenticated.Load() { |
nothing calls this directly
no test coverage detected