openstack/deb-python-autobahn
Code Issues Proposed changes

fix some example bugs

Browse Source
This commit is contained in:
Tobias Oberstein
2014-03-13 16:12:20 +01:00
parent fc3eaaa299
commit ed94424c24
3 changed files with 5 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
examples/twisted/wamp/basic/pubsub/options/backend.js
View File

@@ -16,7 +16,7 @@ connection.onopen = function (session) {
setInterval(function () { setInterval(function () {
var options = {acknowledge: true, discloseme: true}; var options = {acknowledge: true, disclose_me: true};
session.publish('com.myapp.topic1', [counter], {}, options).then( session.publish('com.myapp.topic1', [counter], {}, options).then(
function (publication) { function (publication) {

3
examples/twisted/wamp/basic/rpc/options/backend.js
View File

@@ -14,10 +14,11 @@ connection.onopen = function (session) {
function square(args, kwargs, details) { function square(args, kwargs, details) {
console.log("Someone is calling me;)", details); console.log("Someone is calling me;)", details);
var val = args[0]; var val = args[0];
if (val < 0) { if (val < 0) {
session.publish('com.myapp.square_on_nonpositive', [val]); session.publish('com.myapp.square_on_nonpositive', [val]);
} else { } else if (val === 0) {
var options = {}; var options = {};
if (details && details.caller) { if (details && details.caller) {
options = {exclude: [details.caller]}; options = {exclude: [details.caller]};

6
examples/twisted/wamp/basic/rpc/options/frontend.js
View File

@@ -15,7 +15,7 @@ var connection = new autobahn.Connection({
connection.onopen = function (session) { connection.onopen = function (session) {
function on_event(val) { function on_event(val) {
console.log("Someone requested to square non-negative:", val); console.log("Someone requested to square non-positive:", val);
} }
session.subscribe('com.myapp.square_on_nonpositive', on_event); session.subscribe('com.myapp.square_on_nonpositive', on_event);
@@ -25,7 +25,7 @@ connection.onopen = function (session) {
var vals = [2, 0, -2]; var vals = [2, 0, -2];
for (var i = 0; i < vals.length; ++i) { for (var i = 0; i < vals.length; ++i) {
dl.push(session.call('com.myapp.square', [vals[i]], {}, {discloseme: true}).then( dl.push(session.call('com.myapp.square', [vals[i]], {}, {disclose_me: true}).then(
function (res) { function (res) {
console.log("Squared", res); console.log("Squared", res);
}, },
@@ -38,11 +38,9 @@ connection.onopen = function (session) {
when.all(dl).then( when.all(dl).then(
function () { function () {
console.log("All finished."); console.log("All finished.");
connection.close();
}, },
function () { function () {
console.log("Error", arguments); console.log("Error", arguments);
connection.close();
}); });
}; };