0.1.1 • Published 11 years ago
stream-rpc v0.1.1
stream-rpc
RPC over arbitrary streams
rpc = require 'stream-rpc'
client = rpc(timeout: 1000)
server = rpc
handle: (request, done) ->
done(null, request)
client.pipe(server).pipe(client)
or
{json} = require 'stream-serializer'
client
.pipe(json)
.pipe(serverConnectedSocket)
.pipe(json)
.pipe(client)
server
.pipe(json)
.pipe(clientConnectedSocket)
.pipe(json)