()
| 73 | protected _producer: Producer | null = null; |
| 74 | |
| 75 | get consumer(): Consumer { |
| 76 | if (!this._consumer) { |
| 77 | throw new Error( |
| 78 | 'No consumer initialized. Please, call the "connect" method first.', |
| 79 | ); |
| 80 | } |
| 81 | return this._consumer; |
| 82 | } |
| 83 | |
| 84 | get producer(): Producer { |
| 85 | if (!this._producer) { |
no outgoing calls
no test coverage detected