Rocket.Chat.RealTime.API.RxJS
v2.1.1
Абстракция для использования методов API Rocket.Chat с RXJS V6
npm install --save rocket.chat.realtime.api.rxjs
Для версии пакета 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.
| Методы | Функциональность |
|---|---|
| ConnectToServer () | Инициирует соединения с сервером с API в реальном времени. Возвращает наблюдаемый с ответом сервера |
| KeepAlive () | Возвращает наблюдаемый на подписку, который отвечает «pong» на сообщение «Ping», отправленное API в реальном времени. Чтобы поддерживать связь в живых. |
| Вход (имя пользователя, пароль) | Возвращает наблюдаемый результат/ответ из API в реальном времени. |
| LoginWithAuthtoken (AuthToken) | Возвращает наблюдаемый результат/ответ из API в реальном времени. |
| LoginWithoAuth (credtoken, credsecret) | Возвращает наблюдаемый результат/ответ из API в реальном времени. |
| Callmethod (Methodname, ... Params) | Возвращает наблюдаемый с результатом вызова метода из Rocket.chat Realtime API |
| SendMessage (jsonObject) | Отправляет объект JSON на сервер API |
| onMessage (message => console.log (сообщение)) | Подписывается на сообщения, отправленные с сервера |
| OnError (error => console.error (error)) | Подписывается на ошибки. |
| Oncomplotion (() => console.info ("overse"))) | Подписывается на завершение подключения к WebSocket |
| Подписаться (MessageHandler, ErrorHandler, ApplyionHandler) | Подписывается на все три IE - сообщения, ошибки и завершение |
| getObServable () | Возвращает наблюдаемое подключение к WebSocket с API в реальном времени |
| Densoncect () | Отсоедините соединение WebSocket между клиентом и API в реальном времени |
