// vtest build: !windows
// vtest retry: 2
import os
import time

fn test_input_rune_iterator_with_unicode_input() {
	mut p := os.new_process(@VEXE)
	p.set_args(['-e', 'for i, r in input_rune_iterator() { println("> i: \${i:04} | r: `\${r}`") }'])
	p.set_redirect_stdio()
	p.run()
	spawn fn [mut p] () {
		time.sleep(10 * time.millisecond)
		dump(p.pid)
		p.stdin_write('Проба Abc 你好 🌍 123')
		time.sleep(10 * time.millisecond)
		p.stdin_write('\0x00') // 0 should break the input stream
		time.sleep(10 * time.millisecond)
		eprintln('>>> done')
	}()
	mut olines := []string{}
	for p.is_alive() {
		if oline := p.pipe_read(.stdout) {
			olines << oline
		}
		time.sleep(1 * time.millisecond)
	}
	p.close()
	p.wait()
	assert p.code == 0
	eprintln('done')
	solines := olines.join('\n').trim_space().replace('\r', '')
	eprintln('solines.len: ${solines.len} | solines: ${solines}')
	assert solines.len > 100
	assert solines == '> i: 0000 | r: `П`
> i: 0001 | r: `р`
> i: 0002 | r: `о`
> i: 0003 | r: `б`
> i: 0004 | r: `а`
> i: 0005 | r: ` `
> i: 0006 | r: `A`
> i: 0007 | r: `b`
> i: 0008 | r: `c`
> i: 0009 | r: ` `
> i: 0010 | r: `你`
> i: 0011 | r: `好`
> i: 0012 | r: ` `
> i: 0013 | r: `🌍`
> i: 0014 | r: ` `
> i: 0015 | r: `1`
> i: 0016 | r: `2`
> i: 0017 | r: `3`'
}