async #poll(blockNumber: number): Promise<void> {
        // The initial block hasn't been determined yet
        if (this.#blockNumber === -2) { return; }

        const filter = copy(this.#filter);
-       filter.fromBlock = this.#blockNumber + 1;
-       filter.toBlock = blockNumber;
+       filter.fromBlock = Math.min(this.#blockNumber + 1, blockNumber);
+       filter.toBlock = Math.max(this.#blockNumber + 1, blockNumber);

        const logs = await this.#provider.getLogs(filter);

        // No logs could just mean the node has not indexed them yet,
        // so we keep a sliding window of 60 blocks to keep scanning
        if (logs.length === 0) {
            if (this.#blockNumber < blockNumber - 60) {
                this.#blockNumber = blockNumber - 60;
            }
            return;
        }

        for (const log of logs) {
            this.#provider.emit(this.#filter, log);

            // Only advance the block number when logs were found to
            // account for networks (like BNB and Polygon) which may
            // sacrifice event consistency for block event speed
-           this.#blockNumber = log.blockNumber;
+           this.#blockNumber = Math.max(this.#blockNumber, log.blockNumber);
        }
    }