(request []byte)
| 206 | } |
| 207 | |
| 208 | func (h *Host) callHostHTTPStreamClose(request []byte) ([]byte, error) { |
| 209 | var req rpcHostHTTPStreamCloseRequest |
| 210 | if errUnmarshal := json.Unmarshal(request, &req); errUnmarshal != nil { |
| 211 | return nil, fmt.Errorf("decode host http stream close request: %w", errUnmarshal) |
| 212 | } |
| 213 | if h != nil && h.httpStreams != nil { |
| 214 | h.httpStreams.close(req.StreamID) |
| 215 | } |
| 216 | return marshalRPCResult(rpcEmptyResponse{}) |
| 217 | } |
| 218 | |
| 219 | func decodeHostHTTPRequest(raw []byte) (pluginapi.HTTPRequest, error) { |
| 220 | httpReq, _, errDecode := decodeHostHTTPRequestWithCallbackID(raw) |
no test coverage detected