Skip to content

Instantly share code, notes, and snippets.

@possibilities
Created August 23, 2012 22:53
Show Gist options
  • Save possibilities/3443021 to your computer and use it in GitHub Desktop.
Save possibilities/3443021 to your computer and use it in GitHub Desktop.
Meteor Async Guide

From Meteor's documentation:

In Meteor, your server code runs in a single thread per request, not in the asynchronous callback style typical of Node. We find the linear execution model a better fit for the typical server code in a Meteor application.

This guide serves as a mini-tour of tools, trix and patterns that can be used to run async code in Meteor.

Basic async

Sometimes we need to run async code in Meteor.methods. For this we create a Future to block until the async code has finished. This pattern can be seen all over Meteor's own codebase:

Meteor.methods({
  asyncJob: function(message) {
  
    // Set up a future
    var fut = new Future();

    // This should work for any async method
    setTimeout(function() {

      // Return the results
      fut.ret(message + " (delayed for 3 seconds)");

    }, 3 * 1000);

    // Wait for async to finish before returning
    // the result
    return fut.wait();
  }
});

Code

Parallel async

Sometimes we want to run more than one async methods in parallel and wait for them all to complete before returning:

Meteor.methods({
  parallelAsyncJob: function(message) {

    // We're going to make http get calls to each url
    var urls = [
      'http://google.com',
      'http://news.ycombinator.com',
      'https://github.com'
    ];

    // Keep track of each job in an array
    var futures = _.map(urls, function(url) {

      // Set up a future for the current job
      var future = new Future();

      // A callback so the job can signal completion
      var onComplete = future.resolver();

      /// Make async http call
      Meteor.http.get(url, function(error, result) {

        // Do whatever you need with the results here!
    
        // Inform the future that we're done with it
        onComplete(error, result);
      });

      // Return the future
      return future;
    });

    Future.wait(futures);
  }
});

Code

If you want to collect results from parallel async jobs you'll have to do a little more work:

Meteor.methods({
  parallelAsyncJob: function(message) {
    var urls = [
      'http://google.com',
      'http://news.ycombinator.com',
      'https://github.com'
    ];

    var futures = _.map(urls, function(url) {
      var future = new Future();
      var onComplete = future.resolver();
  
      /// Make async http call
      Meteor.http.get(url, function(error, result) {

        // Get the title if there was no error
        var title = (!error) && getTitle(result);
    
        onComplete(error, title);
      });
  
      return future;
    });

    // wait for all futures to finish
    Future.wait(futures);

    // and grab the results out.
    return _.invoke(futures, 'get'); 
  }
});

Code

Unblocking Meteor.methods

Each approach described so far breaks from Meteor's default synchronous programming style, but requests from a given client are still processed one at a time. If you have a method that could take a long time call this.unblock() and subsequent requests will be run in a new fiber.

Meteor.methods({
  moveForkliftToBuilding9: function(message) {
    this.unblock();
    forklift.moveTo({ building: 9 })
  }
});

Note: borrowed this method name from Matt Debergalis because I think it's hilarious

Accessing Meteor's full environment from async callbacks

If you need to access Meteor's full environment in an asynchronous method's callback Meteor provides a wrapper called Meteor.bindEnvironment:

TODO make better example

var fn = function(error, result) {
  console.log('done ' + result);
};

fn = Meteor.bindEnvironment(callback, function(e) {
  var message = "Something went wrong! " +
                "Everything is broken! " + 
                "Your life is ruined!";

  console.log(message, e.stack);
});

myAsyncMethodThatNeedAccessToMeteorEnv(fn);

Packaging async node modules

TODO

Abstractions

At this point I'm leaving this purposely unfinished because until I have opportunities to use these techniques more than once, in real apps, I don't want to guess what the right abstractions are. Hopefully people will write awesome smart packages for this stuff and we can find out together what will be most effective and then campaign for our favorites to be be included in core.

TODO

Include all useful info mentioned by Matt here

Instead of example like asyncJob and parallelAsyncJob come up with meaningful names and implementations

Contributions

Thanks to the following people for their help with this:

Tom Coleman @tmeasday

Resources

http://stackoverflow.com/a/11510874

@skozz
Copy link

skozz commented Jul 14, 2014

This gist is awesome but bro it's deprecated.

Stackoverflow topic for Meteor 0.8+ http://stackoverflow.com/questions/24743402/how-to-get-an-async-data-in-a-function-with-meteor

@Overload119
Copy link

+1 On the updated documentation.

Here's an example of how I'm using this with GeoNear that isn't supported using just Meteor yet.

Meteor.methods({
  searchQuery: function(searchParams, callback) {
    // Look through skills and work experience.
    // Sort by distance (using $near forces this).
    // Limit of 100 is also enforced by $near.
    // TODO Incorporate recently active
    check(searchParams, Object);

    if (!this.userId) {
      throw new Meteor.Error('User is not logged in');
    }

    if (!searchParams.term) {
      throw new Meteor.Error('Search parameters did not contain `term`.');
    }

    var asyncDbLookup = function(callback) {
      _db.command({
        geoNear: 'users',
        near: [searchParams.lat, searchParams.lng],
        limit: 30,
        query: {
          $or: [
            { interests: searchParams.term },
            { skills: searchParams.term },
            { jobExperience: searchParams.term }
          ]
        }
      }, function(err, res) {
        var results = [];

        // Pluck only the fields we want.
        if (res.results && res.results.length > 0) {
          results = _.map(res.results, function(entry) {
            var mappedEntry = _.pick(entry.obj, '_id', 'pictureUrl', 'headline', 'firstName');
            mappedEntry.distance = entry.dis;

            return mappedEntry
          });
        }

        callback(null, results);
      });
    };

    var syncDbLookup = Meteor.wrapAsync(asyncDbLookup);
    return syncDbLookup();
  }
});

@dennisharrison
Copy link

@Overload119 - excellent example, thank you!

@Vingdc
Copy link

Vingdc commented May 12, 2015

@Overload119 Thank you very much! finally understood how Async works on Meteor!

@kublermdk
Copy link

The rest of the Javascript world use Promises which is effectively what you have here.
Thank you for bringing this to Meteor.

@marxo
Copy link

marxo commented Dec 24, 2015

Is there a fresh up-to-date fork of this or is this still considered valid?

@thiagodelgado111
Copy link

Hey, great article! Can you put up a few samples of how to use async/await syntax in Meteor server methods definition? :)

@Dartv
Copy link

Dartv commented Jul 20, 2016

+1 for async/await

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment