We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 2c582c8 commit cc5ea08Copy full SHA for cc5ea08
1 file changed
integration/microservices/e2e/sum-kafka.spec.ts
@@ -37,21 +37,21 @@ describe('Kafka transport', () => {
37
setTimeout(() => {
38
expect(KafkaController.MATH_SUM).to.eq(15);
39
done();
40
- }, 1000);
+ }, 4000);
41
});
42
- });
+ }).timeout(5000);
43
44
- it(`/POST (event notification)`, done => {
+ it(`/POST (async event notification)`, done => {
45
request(server)
46
.post('/notify')
47
.send([1, 2, 3, 4, 5])
48
.end(() => {
49
50
expect(KafkaController.IS_NOTIFIED).to.be.true;
51
52
53
54
55
56
after(`Stopping Kafka app`, async () => {
57
await app.close();
0 commit comments