0.1.5: Fixed subscription ready property

Fixes numtel#11

Author: numtel

.versions

@@ -1,38 +1,36 @@
-application-configuration@1.0.4
-autopublish@1.0.2
-base64@1.0.2
-binary-heap@1.0.2
-blaze@2.0.4
-blaze-tools@1.0.2
-callback-hook@1.0.2
-check@1.0.4
-ddp@1.0.14
-deps@1.0.6
-ejson@1.0.5
-follower-livedata@1.0.3
-geojson-utils@1.0.2
-html-tools@1.0.3
-htmljs@1.0.3
-id-map@1.0.2
-insecure@1.0.2
-jquery@1.11.3
-json@1.0.2
-local-test:numtel:mysql@0.1.4
-logging@1.0.6
-meteor@1.1.4
-minifiers@1.1.3
-minimongo@1.0.6
-mongo@1.0.11
-numtel:mysql@0.1.4
-observe-sequence@1.0.4
-ordered-dict@1.0.2
-random@1.0.2
-reactive-var@1.0.4
-retry@1.0.2
-sharlon:6to5@0.0.1
-spacebars-compiler@1.0.4
-templating@1.0.11
-test-helpers@1.0.3
-tinytest@1.0.4
-tracker@1.0.5
-underscore@1.0.2
+autopublish@1.0.3
+base64@1.0.3
+binary-heap@1.0.3
+blaze@2.1.2
+blaze-tools@1.0.3
+callback-hook@1.0.3
+check@1.0.5
+ddp@1.1.0
+deps@1.0.7
+ejson@1.0.6
+geojson-utils@1.0.3
+grigio:babel@0.1.1
+html-tools@1.0.4
+htmljs@1.0.4
+id-map@1.0.3
+insecure@1.0.3
+jquery@1.11.3_2
+json@1.0.3
+local-test:numtel:mysql@0.1.5
+logging@1.0.7
+meteor@1.1.6
+minifiers@1.1.5
+minimongo@1.0.8
+mongo@1.1.0
+numtel:mysql@0.1.5
+observe-sequence@1.0.6
+ordered-dict@1.0.3
+random@1.0.3
+reactive-var@1.0.5
+retry@1.0.3
+spacebars-compiler@1.0.6
+templating@1.1.1
+test-helpers@1.0.4
+tinytest@1.0.5
+tracker@1.0.7
+underscore@1.0.3

lib/LiveMysql.js

@@ -1,11 +1,14 @@
 // numtel:mysql
 // MIT License, ben@latenightsketches.com
 // lib/LiveMysql.js
+var Future = Npm.require('fibers/future');
+
 LiveMysql = Npm.require('mysql-live-select');
 
 // Convert the LiveMysqlSelect object into a cursor
 LiveMysql.LiveMysqlSelect.prototype._publishCursor = function(sub) {
   var self = this;
+  var fut = new Future;
   var initLength;
 
   sub.onStop(function(){
@@ -23,7 +26,7 @@ LiveMysql.LiveMysqlSelect.prototype._publishCursor = function(sub) {
   self.on('update', function(rows){
     if(sub._ready === false){
       initLength = rows.length;
-      if(initLength === 0) sub.ready();
+      if(initLength === 0) fut['return']();
     }
   });
 
@@ -43,9 +46,11 @@ LiveMysql.LiveMysqlSelect.prototype._publishCursor = function(sub) {
   selectHandler('added', 0, 1, function(){
     if(sub._ready === false &&
        self.data.length === initLength - 1){
-      sub.ready();
+      fut['return']();
     }
   });
   selectHandler('changed', 1, 2);
   selectHandler('removed', null, 1);
+
+  return fut.wait()
 }

package.js

@@ -1,7 +1,7 @@
 Package.describe({
   name: 'numtel:mysql',
   summary: 'MySQL support with Reactive Select Subscriptions',
-  version: '0.1.4',
+  version: '0.1.5',
   git: 'https://github.com/numtel/meteor-mysql.git'
 });
 
@@ -32,7 +32,7 @@ Package.onTest(function(api) {
     'underscore',
     'autopublish',
     'insecure',
-    'sharlon:6to5',
+    'grigio:babel@0.1.1',
     'numtel:mysql'
   ]);
   api.use('test-helpers'); // Did not work concatenated above