function RpcMessage(opts) {
    assert.object(opts, 'options');
    assert.bool(opts.incoming, 'options.incoming');
    assert.optionalNumber(opts.type, 'options.type');
    assert.optionalNumber(opts.xid, 'options.xid');

    stream.Transform.call(this, opts);

    this.type = opts.type;
    this.xid = opts.xid;

    this.incoming = opts.incoming;

    this._rpc_wrote_head = false;

    this._rpc_message = true; // MDB
}
function RpcMessage(opts) {
    assert.object(opts, 'options');
    assert.bool(opts.incoming, 'options.incoming');
    assert.optionalNumber(opts.type, 'options.type');
    assert.optionalNumber(opts.xid, 'options.xid');

    stream.Transform.call(this, opts);

    this.type = opts.type;
    this.xid = opts.xid;

    this.incoming = opts.incoming;

    this._rpc_wrote_head = false;

    this._rpc_message = true; 
}
function RpcMessage ( opts ) { assert . object ( opts , 'options' ) ; assert . bool ( opts . incoming , 'options.incoming' ) ; assert . optionalNumber ( opts . type , 'options.type' ) ; assert . optionalNumber ( opts . xid , 'options.xid' ) ; stream . Transform . call ( this , opts ) ; this . type = opts . type ; this . xid = opts . xid ; this . incoming = opts . incoming ; this . _rpc_wrote_head = false ; this . _rpc_message = true ; // MDB }
/--- API
/ --- API