lib/message.js
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; // MDB
}
/--- API