Rocket.Chat.RealTime.API.RxJS
v2.1.1
Abstraksi untuk menggunakan roket. Metode API realtime dengan RXJS V6
npm install --save rocket.chat.realtime.api.rxjs
Untuk versi paket RXJS V5
npm install --save [email protected]
import { RealTimeAPI } from "rocket.chat.realtime.api.rxjs";
const realTimeAPI = new RealTimeAPI("wss://demo.rocket.chat/websocket");
// Provide, URL to the Rocket.Chat's Realtime API.
realTimeAPI.keepAlive().subscribe();
// Responds "pong" to the "ping" message sent by the Realtime API. To keep the connection alive.
const auth = realTimeAPI.login(USERNAME, PASSWORD);
// Creating Observable
//Now subscribing the observable
auth.subscribe(
(data) => console.log(data),
(err) => console.log(err),
() => console.log('completed'));
...
...
// Use any of the methods implmented in the package.
| Metode | Fungsionalitas |
|---|---|
| ConnectToServer () | Memulai koneksi ke server ke API realtime. Mengembalikan dapat diamati dengan respons server |
| Keepalive () | Pengembalian yang dapat diamati untuk berlangganan yang merespons "pong" ke pesan "ping" yang dikirim oleh API realtime. Untuk menjaga koneksi tetap hidup. |
| Login (nama pengguna, kata sandi) | Mengembalikan dapat diamati dengan hasil/respons dari API realtime. |
| LoginwithAuthToken (AuthToken) | Mengembalikan dapat diamati dengan hasil/respons dari API realtime. |
| LoginwithoAuth (CredToken, CredSecret) | Mengembalikan dapat diamati dengan hasil/respons dari API realtime. |
| callmethod (MethodName, ... params) | Mengembalikan dapat diamati dengan hasil panggilan metode dari rocket.chat realtime API |
| sendmessage (jsonObject) | Mengirimkan objek JSON ke server API |
| onMessage (message => console.log (pesan)) | Berlangganan pesan yang dikirim dari server |
| onError (error => console.error (error)) | Berlangganan kesalahan. |
| OnCompletion (() => Console.info ("Lengkap")) | Berlangganan selesai pada koneksi WebSocket |
| Berlangganan (MessageHandler, Errorhandler, CompletionHandler) | Berlangganan ke ketiga IE - pesan, kesalahan dan penyelesaian |
| getobservable () | Mengembalikan Koneksi Websocket ke API Realtime |
| memutuskan() | Putuskan sambungan koneksi WebSocket antara klien dan API realtime |
