export function strFirstBit(val) {
|
let arr = val.map((val, index, arr) => {
|
return val.currency;
|
});
|
return arr;
|
}
|
export function filterArrayEmpty(val) {
|
let isEmpty = val.every((val) => {
|
return val != "";
|
});
|
return isEmpty;
|
}
|
export class WhrWebSocket {
|
constructor(params) {
|
//只有params这个参数必须卸载constructor方法里，其他的实例属性可以写在外面
|
// 比如 socket = null
|
this.socket = null;
|
this.params = params;
|
this.j = 0; //websocket重连次数
|
this.i = 0; //发送信息次数
|
}
|
|
init(params) {
|
if (this.params.path) {
|
this.path = this.params.path;
|
} else {
|
throw new Error("参数socket服务器地址path必须存在");
|
}
|
this.socket = new WebSocket(this.path);
|
// this.socket.send('key:eVKtHt7aG4m6ozwWL9qG')
|
console.log('已连接到服务器');
|
this.socket.onopen = () => {
|
// console.log("连接开启");
|
};
|
// this.socket.onclose = () => {
|
|
// console.log("连接关闭")
|
// this.reconnect()
|
// }
|
// this.socket.onerror = () => {
|
// console.log("连接错误")
|
// }
|
this.socket.onmessage = this.params.onmessage;
|
}
|
|
// getMessage(msg) {
|
// console.log("收到的消息", msg)
|
// return msg
|
// }
|
|
close() {
|
clearTimeout(this.time);
|
this.socket.close(1000, "手动关闭");
|
}
|
}
|
