Rocket.Chat.RealTime.API.RxJS
v2.1.1
Abstração para utilizar o Rocket.Chat em tempo real dos métodos com rxjs v6
npm install --save rocket.chat.realtime.api.rxjs
Para a versão RXJS V5 do pacote
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 | Funcionalidade |
|---|---|
| ConnectToserver () | Inicia conexões com o servidor com a API em tempo real. Retorna observável com a resposta do servidor |
| Keepalive () | Retorna observável para se inscrever que responde "Pong" à mensagem "ping" enviada pela API em tempo real. Para manter a conexão viva. |
| Login (nome de usuário, senha) | Retorna observável ao resultado/resposta da API em tempo real. |
| LoginwithauthToken (AuthToken) | Retorna observável ao resultado/resposta da API em tempo real. |
| LoginWithoauth (Credtoken, Credsecret) | Retorna observável ao resultado/resposta da API em tempo real. |
| callMethod (MethodName, ... params) | Retornos observáveis ao resultado da chamada do método da API Rocket.Chat Real Time |
| SendMessage (JsonObject) | Envia o objeto JSON para o servidor API |
| onMessage (Mensagem => Console.log (Mensagem)) | Assina as mensagens enviadas do servidor |
| OnError (Error => Console.error (Erro)) | Assina os erros. |
| Oncompletion (() => console.info ("Complete"))) | Assina a conclusão na conexão WebSocket |
| Inscreva -se (MessageHandler, ErrorHandler, conclusão) | Assina todos os três IE - mensagens, erros e conclusão |
| getobservable () | Retorna observável da conexão WebSocket com a API em tempo real |
| desconectar () | Desconecte a conexão do WebSocket entre o cliente e a API em tempo real |
