(expectedResp models.HTTPResp)
| 1375 | } |
| 1376 | |
| 1377 | func expectedBinaryBytes(expectedResp models.HTTPResp) []byte { |
| 1378 | if len(expectedResp.StreamBody) > 0 { |
| 1379 | var buf bytes.Buffer |
| 1380 | for _, chunk := range expectedResp.StreamBody { |
| 1381 | raw, ok := streamChunkFieldValue(chunk, "raw") |
| 1382 | if ok { |
| 1383 | buf.WriteString(raw) |
| 1384 | } |
| 1385 | } |
| 1386 | if buf.Len() > 0 { |
| 1387 | return buf.Bytes() |
| 1388 | } |
| 1389 | } |
| 1390 | return []byte(expectedResp.Body) |
| 1391 | } |
| 1392 | |
| 1393 | func extractExpectedSSEQueue(expectedResp models.HTTPResp) []expectedSSEFrame { |
| 1394 | if len(expectedResp.StreamBody) == 0 { |
no test coverage detected