Thruway.js

This project is a WAMP v2 client written in TypeScript that uses RxJS v5 Observables instead of promises and event emitters.
It's designed to work with modern frontend frameworks like Angular v2/4 as well as node.js.

If you don't know what WAMP is, you should read up on it.

If you don't know what RxJS or ReactiveExtensions is, you're missing out...

note: This library is stable, but may not have all of the WAMP features implemented. Since this project originated as an internal project for Voryx, the features are limited to only the ones that were needed.

Installation

``BASH
npm install thruway.js
npm install rxjs
npm install ws // only when using with Node
`

Usage

`JS
import {Client} from "thruway.js";

const wamp = new Client('ws://localhost:9090', 'realm1');
`

$3

`JS
wamp.call('add.rpc', [1, 2])
.map((r: ResultMessage) => r.args[0])
.subscribe(r => console.log(r));
`

$3

`JS
wamp.register('add.rpc', (a, b) => a + b).subscribe();
`

If you need keyword arguments, you can set the extended option.

`JS
wamp.register('add.rpc', (args, argskw) => argskw.a + argskw.b, {extended: true}).subscribe();
`

$3

`JS
wamp.publish('example.topic', 'some value');
wamp.publish('example.topic', Observable.interval(1000)); // you can also publish an observable

`

$3

`JS
wamp.topic('example.topic').subscribe((v)=>console.log(v));
`

$3

Create a wamp service

`JS
import {Injectable} from '@angular/core';
import {Client} from 'thruway.js';

@Injectable()
export class WampService extends Client {
constructor() {
super('wss://demo.crossbar.io/ws', 'realm1');
}
}
`

Inject and use the service in your component

`JS
import {Component} from '@angular/core';
import {WampService} from '../wamp.service';
import {Observable} from 'rxjs/Observable';
import {EventMessage} from 'thruway.js/src/Messages/EventMessage';

@Component({
selector: 'app-counter',
template: '{{counter | async}}'
})
export class CounterComponent {
counter: Observable = this.wamp
.topic('com.myapp.counter')
.map((r: EventMessage) => r.args[0]);

constructor(private wamp: WampService) {}
}
`

$3

`JS
const Thruway = require("thruway.js");
const Rx = require("rxjs");

const wamp = new Thruway.Client('wss://demo.crossbar.io/ws', 'realm1');

wamp.publish('com.myapp.counter', Rx.Observable.interval(1000));
`

$3

Install the RxThruway Client

`BASH
composer require rx/thruway-client

`

`PHP


use Rx\Observable;
use Rx\Thruway\Client;

require __DIR__ . '/vendor/autoload.php';

$wamp = new Client('wss://demo.crossbar.io/ws', 'realm1');

$wamp->publish('com.myapp.counter', Observable::interval(1000));
``