This is an automated email from the ASF dual-hosted git repository.

bhulette pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/arrow.git


The following commit(s) were added to refs/heads/master by this push:
     new 1d9b834  ARROW-2225: [JS] support tables split across buffers
1d9b834 is described below

commit 1d9b8347467d6e915977e8ecc9b0759f86fd745a
Author: Paul Taylor <[email protected]>
AuthorDate: Wed Feb 28 14:37:07 2018 -0500

    ARROW-2225: [JS] support tables split across buffers
    
    @TheNeuralBit somewhere along the way we lost this. Resolves 
https://issues.apache.org/jira/browse/ARROW-2225
    
    Author: Paul Taylor <[email protected]>
    
    Closes #1670 from trxcllnt/js-fix-multiple-buffers and squashes the 
following commits:
    
    869cd74 <Paul Taylor> 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 6e3c7fc..26bc10b 100644
--- a/js/src/ipc/reader/binary.ts
+++ b/js/src/ipc/reader/binary.ts
@@ -49,7 +49,7 @@ export function* readBuffers<T extends Uint8Array | Buffer | 
string>(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<T extends Uint8Array 
| Buffer | string>(
     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,

-- 
To stop receiving notification emails like this one, please contact
[email protected].

Reply via email to