executeStreaming handles streaming scenarios with sequences
(t *testing.T, scenario Scenario)
| 209 | |
| 210 | // executeStreaming handles streaming scenarios with sequences |
| 211 | func (e *executor) executeStreaming(t *testing.T, scenario Scenario) { |
| 212 | t.Helper() |
| 213 | |
| 214 | ctx := context.Background() |
| 215 | |
| 216 | // Only WebSocket and SSE support streaming |
| 217 | switch scenario.Transport { |
| 218 | case TransportWebSocket: |
| 219 | e.executeWebSocketSequence(ctx, t, scenario) |
| 220 | case TransportSSE: |
| 221 | e.executeSSESequence(ctx, t, scenario) |
| 222 | default: |
| 223 | require.Failf(t, "Unsupported transport", "Transport %s does not support streaming", scenario.Transport) |
| 224 | } |
| 225 | } |
| 226 | |
| 227 | // executeWebSocketSequence handles WebSocket streaming sequences |
| 228 | func (e *executor) executeWebSocketSequence(ctx context.Context, t *testing.T, scenario Scenario) { |
no test coverage detected