public Iterable < QueryResult > traverse ( final InputStream is ) { MessageUnpacker unpacker = MessagePack . newDefaultUnpacker ( is ) ; return ( ) -> { return new Iterator < QueryResult > ( ) { @ Override public boolean hasNext ( ) { try { return unpacker . hasNext ( ) ; } catch ( IOException e ) { throw new InfluxDBException ( e ) ; } } @ Override public QueryResult next ( ) { return parse ( unpacker ) ; } } ; } ; }
Traverse over the whole message pack stream . This method can be used for converting query results in chunk .