(subscriber: AgentSubscriber)
| 63 | } |
| 64 | |
| 65 | override subscribe(subscriber: AgentSubscriber) { |
| 66 | const sub = super.subscribe(subscriber); |
| 67 | return { |
| 68 | unsubscribe: () => { |
| 69 | sub.unsubscribe(); |
| 70 | this.unsubscribeCount += 1; |
| 71 | }, |
| 72 | }; |
| 73 | } |
| 74 | |
| 75 | emitMessages(messages: Message[]) { |
| 76 | this.messages = messages; |
nothing calls this directly
no test coverage detected