(ctx context.Context, request []byte)
| 140 | } |
| 141 | |
| 142 | func (h *Host) callHostHTTPDo(ctx context.Context, request []byte) ([]byte, error) { |
| 143 | httpReq, callbackID, errDecode := decodeHostHTTPRequestWithCallbackID(request) |
| 144 | if errDecode != nil { |
| 145 | return nil, errDecode |
| 146 | } |
| 147 | ctx = h.resolveCallbackContext(callbackID, ctx) |
| 148 | resp, errDo := h.newHTTPClient(nil).Do(ctx, httpReq) |
| 149 | if errDo != nil { |
| 150 | return nil, errDo |
| 151 | } |
| 152 | return marshalRPCResult(resp) |
| 153 | } |
| 154 | |
| 155 | func (h *Host) callHostHTTPDoStream(ctx context.Context, request []byte) ([]byte, error) { |
| 156 | httpReq, callbackID, errDecode := decodeHostHTTPRequestWithCallbackID(request) |
no test coverage detected