co-thrift v0.2.0

co-thrift

Co wrapper for thrift clients.

The wrapper just searches the prototype for every method, which does not start with send_ or recv_ and replaces it with a version you can yield. This may not be save, but it works for my purpose.

WARNING: The client prototype gets changed. This could be a problem.

Installation

$ npm install co-thrift

Example

Just do as you normally do in thrift, but pass the Client object to the wrapper.

Line:

var client = thrift.createClient(wrapper(StreamingService.Client), connection);
// ...
yield client.establishStream(name, '', port);

Full Example:

var wrapper = require('co-thrift'),
    thrift = require('thrift')
    StreamingService = require('./StreamingService');

var transport = thrift.TFramedTransport;
var protocol = thrift.TBinaryProtocol;

var connection = thrift.createConnection('host', port, {
    transport: transport,
    protocol: protocol
});

connection.on('error', function (err) {
    console.log(err);
});

var client = thrift.createClient(wrapper(StreamingService.Client), connection);

module.exports.establish = function *establish (name) {
    yield client.establishStream(name, '', port);
}

License

ISC