#RStream 实时消息调度客户端

如何使用

安装RStream

npm install rstream

使用样例

import RStream from 'rstream';

const stream = new RStream({
  server: 'http://localhost:3000',
  token: 'test'
});

stream.on('connect_error',(error)=>{
  console.log(error);
});

stream.on('error',(error)=>{
  console.log(error);
});

stream.on('message',(message)=>{
  console.log(message);
});

stream.on('connect',()=>{
  stream.sendMessage({
    to:'topdmc',
    body:{}
  });
});

stream.open();

TODO: message

message:
{
  from:'', //来自appid
  to:'', // 发送的appid
  event:'message', //消息
  sent:1000000, // 发送的时间戳
  content:'', // 消息内容
  createAt:'' //
}

Events

• rstream_error: RPC层的错误消息

• connect_error: Fired upon a connection error. Parameters: Object error object

• connect_timeout: Fired upon a connection timeout. reconnect. Fired upon a successful reconnection. Parameters: Number reconnection attempt number

• reconnect_attempt: Fired upon an attempt to reconnect.

• reconnecting: Fired upon an attempt to reconnect. Parameters: Number reconnection attempt number

• reconnect_error: Fired upon a reconnection attempt error. Parameters: Object error object

• reconnect_failed: Fired when couldn't reconnect within reconnectionAttempts