| | jest.mock('@waylaidwanderer/fetch-event-source', () => ({ |
| | fetchEventSource: jest |
| | .fn() |
| | .mockImplementation((url, { onopen, onmessage, onclose, onerror, error }) => { |
| | |
| | onopen && onopen({ status: 200 }); |
| |
|
| | |
| | onmessage && |
| | onmessage({ data: JSON.stringify({ message: 'First message' }), event: 'message' }); |
| | onmessage && |
| | onmessage({ data: JSON.stringify({ message: 'Second message' }), event: 'message' }); |
| | onmessage && |
| | onmessage({ data: JSON.stringify({ message: 'Third message' }), event: 'message' }); |
| |
|
| | |
| | onclose && onclose(); |
| |
|
| | if (error) { |
| | |
| | onerror && onerror({ status: 500 }); |
| | } |
| |
|
| | |
| | return Promise.resolve(); |
| | }), |
| | })); |
| |
|