diff --git a/js/src/ipc/reader/binary.ts b/js/src/ipc/reader/binary.ts index 6e3c7fc5cf0..26bc10bb377 100644 --- a/js/src/ipc/reader/binary.ts +++ b/js/src/ipc/reader/binary.ts @@ -49,7 +49,7 @@ export function* readBuffers(sources: It } for (const source of sources) { const bb = toByteBuffer(source); - if ((!schema && ({ schema, readMessages } = readSchema(bb))) && schema && readMessages) { + if ((!schema && ({ schema, readMessages } = readSchema(bb)) || true) && schema && readMessages) { for (const message of readMessages(bb)) { yield { schema, message, @@ -71,7 +71,7 @@ export async function* readBuffersAsync( let readMessages: MessageReader | null = null; for await (const source of sources) { const bb = toByteBuffer(source); - if ((!schema && ({ schema, readMessages } = readSchema(bb))) && schema && readMessages) { + if ((!schema && ({ schema, readMessages } = readSchema(bb)) || true) && schema && readMessages) { for (const message of readMessages(bb)) { yield { schema, message,