diff --git a/test/e2e/declare_consumer.test.ts b/test/e2e/declare_consumer.test.ts index 38ce6f3f..00390602 100644 --- a/test/e2e/declare_consumer.test.ts +++ b/test/e2e/declare_consumer.test.ts @@ -72,7 +72,7 @@ describe("declare consumer", () => { await eventually(() => expect(messages).eql([Buffer.from("hello"), Buffer.from("world"), Buffer.from("world")])) }).timeout(10000) - it.skip(`consume a lot of messages`, async () => { + it(`consume a lot of messages`, async () => { const receivedMessages: Buffer[] = [] await connection.declareConsumer({ stream: streamName, offset: Offset.next() }, (message: Message) => { receivedMessages.push(message.content)