From 869cd743ad09d90081661cf343a845fd35b404fc Mon Sep 17 00:00:00 2001 From: Paul Taylor Date: Mon, 26 Feb 2018 17:16:03 -0800 Subject: [PATCH] make the reader work for tables split across buffers again --- js/src/ipc/reader/binary.ts | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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,