# -*- coding: utf-8 -*-
from rpycstream import RPC
from subprocess import Popen, PIPE, STDOUT
def main():
    # python
    worker = Popen(['ssh', 're.mo.te.ip', 'python', 'remote.py'], stdout=PIPE, stdin=PIPE, stderr=STDOUT)
    # nodejs
    # worker = Popen(['ssh', 're.mo.te.ip', 'node', 'remote.js'], stdout=PIPE, stdin=PIPE, stderr=STDOUT)
    # pipe into each other
    rpc = RPC(stdin=worker.stdout, stdout=worker.stdin)
    # remote call
    remote = rpc.wrap(['hello'])
    remote.hello('Carlo', cb)
    # which is equivalent to
    rpc.rpc('hello', ['John'], cb)
def cb(err, msg=None):
    if err:
        raise err
    print "msg:", msg
if __name__ == '__main__':
    main()

# -*- coding: utf-8 -*-
from rpycstream import RPC
class MyClass:
    def hello(self, name):
        return '%s was bitten by a python' % name
if __name__ == '__main__':
    rpc = RPC(target=MyClass())