co-thrift
v0.2.0
Published
Co wrapper for thrift clients.
Downloads
13
Readme
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