Rocket.Chat.RealTime.API.RxJS
v2.1.1
Abstracción para utilizar los métodos de API de tiempo real de Rocket.Chat con RXJS V6
npm install --save rocket.chat.realtime.api.rxjs
Para la versión RXJS V5 del paquete
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.
| Métodos | Funcionalidad |
|---|---|
| ConnectToServer () | Inicia conexiones al servidor a la API de tiempo real. Devuelve observable con la respuesta del servidor |
| KeepAlive () | Devuelve observables para suscribirse que responde "pong" al mensaje "ping" enviado por la API de tiempo real. Para mantener viva la conexión. |
| Iniciar sesión (nombre de usuario, contraseña) | Devuelve observable al resultado/respuesta de la API de tiempo real. |
| LoginwithauthToken (AuthToken) | Devuelve observable al resultado/respuesta de la API de tiempo real. |
| Loginwithoauth (Credtoken, Credsecret) | Devuelve observable al resultado/respuesta de la API de tiempo real. |
| CallMethod (MethodName, ... Params) | Devuelve observable al resultado de la llamada de método desde Rocket.Chat RealTime API |
| sendMessage (jsonObject) | Envía el objeto JSON al servidor API |
| OnMessage (Message => Console.log (Message)) | Se suscribe a los mensajes enviados desde el servidor |
| onError (error => console.error (error)) | Se suscribe a los errores. |
| OnCompletion (() => Console.info ("Complete")) | Se suscribe a la finalización en la conexión WebSocket |
| Suscríbete (MessageHandler, ErrgeHandler, FinalationHandler) | Se suscribe a los tres IE: mensajes, errores y finalización |
| getObServable () | Devuelve observable de la conexión WebSocket a la API de tiempo real |
| desconectar() | Desconecte la conexión WebSocket entre el cliente y la API en tiempo real |
