(data: TMessage)
| 54 | constructor(protected EE: EventEmitter<string, any>) {} |
| 55 | |
| 56 | connect(data: TMessage): Promise<MessageConnect> { |
| 57 | return new Promise((resolve) => { |
| 58 | const EE = new EventEmitter<string, any>(); |
| 59 | const con = new MockMessageConnect(EE); |
| 60 | resolve(con); |
| 61 | sleep(1).then(() => { |
| 62 | this.EE.emit("connect", data, con); |
| 63 | }); |
| 64 | }); |
| 65 | } |
| 66 | |
| 67 | sendMessage<T = any>(data: TMessage): Promise<T> { |
| 68 | return new Promise((resolve) => { |