Run callbacks on schema ready

lib/adapters/memory.js

@@ -1,5 +1,6 @@
 exports.initialize = function initializeSchema(schema, callback) {
     schema.adapter = new Memory();
+    callback();
 };
 
 function Memory() {

lib/adapters/mongoose.js

@@ -6,6 +6,7 @@ var mongoose = require('mongoose');
 exports.initialize = function initializeSchema(schema, callback) {
     schema.client = mongoose.connect(schema.settings.url);
     schema.adapter = new MongooseAdapter(schema.client);
+    callback();
 };
 
 function MongooseAdapter(client) {

lib/adapters/mysql.js

@@ -15,6 +15,7 @@ exports.initialize = function initializeSchema(schema, callback) {
     });
 
     schema.adapter = new MySQL(schema.client);
+    callback();
 };
 
 function MySQL(client) {

lib/adapters/neo4j.js

@@ -6,6 +6,7 @@ var neo4j = require('./neo4j-lib');
 exports.initialize = function initializeSchema(schema, callback) {
     schema.client = new neo4j.GraphDatabase(schema.settings.url);
     schema.adapter = new Neo4j(schema.client);
+    callback();
 };
 
 function Neo4j(client) {

lib/adapters/redis.js

@@ -10,7 +10,8 @@ exports.initialize = function initializeSchema(schema, callback) {
         schema.settings.options
     );
 
-    schema.client.auth(schema.settings.password, callback);
+    schema.client.auth(schema.settings.password);
+    schema.client.on('connect', callback);
 
     schema.adapter = new BridgeToRedis(schema.client);
 };

lib/adapters/sequelize.js

@@ -1,7 +1,8 @@
 var Sequelize = require('sequelize');
 
-exports.initialize = function initializeSchema(schema) {
+exports.initialize = function initializeSchema(schema, callback) {
     schema.adapter = new SequelizeAdapter(schema);
+    callback();
 };
 
 function SequelizeAdapter(schema) {