(req *RpcMessage)
| 310 | } |
| 311 | |
| 312 | func (w *WshRpc) handleStreamAck(req *RpcMessage) { |
| 313 | if w.StreamBroker == nil { |
| 314 | return |
| 315 | } |
| 316 | if req.Data == nil { |
| 317 | return |
| 318 | } |
| 319 | var ackPk wshrpc.CommandStreamAckData |
| 320 | err := utilfn.ReUnmarshal(&ackPk, req.Data) |
| 321 | if err != nil { |
| 322 | return |
| 323 | } |
| 324 | w.StreamBroker.RecvAck(ackPk) |
| 325 | } |
| 326 | |
| 327 | func (w *WshRpc) handleRequestInternal(req *RpcMessage, ingressLinkId baseds.LinkId, pprofCtx context.Context) { |
| 328 | if req.Command == wshrpc.Command_EventRecv { |
no test coverage detected