node package manager
Easy collaboration. Discover, share, and reuse code in your team. Create a free org »

blue-frog-b

blue-frog-b

create a JSON-RPC 2.0 server/client that corresponds to the batch processing.

usage

server

const http     = require('http')
const ecstatic = require('ecstatic')(__dirname + '/static')
const rpc      = require('blue-frog-b')({prefix: '/rpc'})
const app      = http.craeteServer(ecstatic)
 
function add (a, b) { return Number(a) + Number(b) }
 
rpc.on('sum', (params, done) => {
    setTimeout(() => {
        try { done(null, params.reduce(add, 0)) }
        catch (err) { done(err) }
    }, 500)
})
 
rpc.on('add', (params, done) => {
    setTimeout(() => {
        try { done(null, add.apply(null, params)) }
        catch (err) { done(err) }
    }, 800)
})
 
rpc.install(app)
app.listen(9999, () => console.log('listen on port %s', app.address().port))

browser

var hyperquest = require('hyperquest')
var rpc        = require('blue-frog-stream')
var client     = require('blue-frog-b')
 
window.onload = function () {
    var dup = client()
    var hyp = hyperquest.post('http://0.0.0.0:9999/rpc')
 
    hyp.setHeader('content-type', 'application/json')
 
    hyp.on('error', onError)
    dup.on('error', onError)
 
    dup
    .pipe(new rpc.request.BatchStream(true)).on('error', onError)
    .pipe(hyp)
    .pipe(dup)
 
    var sum = dup.request('sum', [1,2,3])
    var add = dup.request('add', [4, 5])
 
    sum.on('error', onError)
    add.on('error', onError)
 
    sum.once('data', function (result) {
        console.log('sum(1, 2, 3) => ', result)
        // 'sum(1, 2, 3) => 6 
    })
    add.once('data', function (result) {
        console.log('add(4, 5) => ', result)
        // 'add(4, 5) => 9 
    })
 
    dup.batch([sum, add])
}
 
function onError (err) {
    console.log(err)
    ;('data' in err) && console.log(err.data)
}

use express

const express = require('express')
const app     = express()
const rpc     = require('blue-frog-b')({prefix: '/rpc'})
 
app.use(express.static('static'))
 
rpc.on('sum', function (params, done) {
// ... 
})
 
rpc.install(app.listen(9999))

api

browser api

var frog = require('blue-frog-b')

var dup = frog()

return a duplex stream. this stream push JSON-RPC 2.0 object.

var tadpole = dup.request(method[, params])

var tadpole = dup.notification(method[, params])

dup.batch(tadpolelist)

author

ishiduca@gmail.com

license

MIT