(elements: Iterable<A>)
| 2097 | } |
| 2098 | |
| 2099 | publishAll(elements: Iterable<A>): Array<A> { |
| 2100 | if (this.publisherTail.subscribers !== 0) { |
| 2101 | for (const a of elements) { |
| 2102 | this.publish(a) |
| 2103 | } |
| 2104 | } else if (this.replayBuffer) { |
| 2105 | this.replayBuffer.offerAll(elements) |
| 2106 | } |
| 2107 | return [] |
| 2108 | } |
| 2109 | |
| 2110 | slide(): void { |
| 2111 | if (this.publisherHead !== this.publisherTail) { |