We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 0e90ccd commit 4611398Copy full SHA for 4611398
test/e2e/declare_consumer.test.ts
@@ -84,7 +84,7 @@ describe("declare consumer", () => {
84
await eventually(() => expect(messages).eql([Buffer.from("hello")]))
85
}).timeout(10000)
86
87
- it("closing a consumer on an existing stream - raises connectionClosedListener", async () => {
+ it.skip("closing a consumer on an existing stream - raises connectionClosedListener", async () => {
88
const messages: Buffer[] = []
89
await publisher.send(Buffer.from("hello"))
90
let called = false
0 commit comments