(request []byte)
| 258 | } |
| 259 | |
| 260 | func (h *Host) callHostStreamClose(request []byte) ([]byte, error) { |
| 261 | var req rpcStreamCloseRequest |
| 262 | if errUnmarshal := json.Unmarshal(request, &req); errUnmarshal != nil { |
| 263 | return nil, fmt.Errorf("decode stream close request: %w", errUnmarshal) |
| 264 | } |
| 265 | h.streams.close(req.StreamID, req.Error) |
| 266 | return marshalRPCResult(rpcEmptyResponse{}) |
| 267 | } |
| 268 | |
| 269 | func (h *Host) callHostModelExecute(ctx context.Context, request []byte) ([]byte, error) { |
| 270 | var req rpcHostModelExecutionRequest |
no test coverage detected