better async intermediate output for polly test

Pollyfile

@@ -138,6 +138,7 @@
       {"run"=>{"name"=>"config","command"=>"bundle config set --local path vendor/bundle"}},
       {"run"=>{"name"=>"bundler","command"=>"bundle install"}},
       {"run"=>{"name"=>"rspec","command"=>"bundle exec rspec"}},
+      {"run"=>{"name"=>"demo","command"=>"polly help"}},
       #{"run"=>{"name"=>"build","command"=>"pwd && ls -l && buildctl --timeout 120 --addr tcp://polly-buildkitd:1234 --tlsservername polly-buildkitd --tlscacert /certs/client/ca.pem --tlscert /certs/client/cert.pem --tlskey /certs/client/key.pem build --frontend dockerfile.v0 --local context=. --local dockerfile=."}}
     ],{},"/home/app/polly"
   )

bin/polly

@@ -1681,13 +1681,16 @@ HEREDOC
 
       #puts kube_exec_cmd.inspect #join(" ")
 
-      o,e,s = exe.execute_simple(:output, kube_exec_cmd, {})
+      s = exe.execute_simple(:async_wait_status, kube_exec_cmd, {}) #{:out => $stdout, :err => $stderr})
 
       if s
-        puts o
+        #puts o
+        puts "OKOK"
       else
-        puts e
+        #puts e
         #fail
+        puts "fail"
+        fail
       end
     end
   end

lib/polly/execute.rb

@@ -836,6 +836,48 @@ def execute_simple(mode, cmd, options)
           o, e, s = Open3.capture3(*cmd, options)
           return exit_proc.call(o, e, s, false)
 
+        when :async_wait_status
+          #o, e, s = Open3.capture3(*cmd, options)
+          #puts options.inspect
+          $stdout.sync = true
+          $stderr.sync = true
+
+          i, o, e, s = Open3.popen3(*cmd, options)
+
+          read_io = Proc.new {
+            chunk = 65432
+            begin
+              stdout = o.read_nonblock(chunk)
+              $stdout.write(stdout)
+            rescue IO::EAGAINWaitReadable, Errno::EIO, Errno::EAGAIN, Errno::EINTR => err
+              #_r, _w, _e = IO.select(process_fds, nil, process_fds, 0.5)
+              sleep 0.1
+            rescue EOFError => err
+            end
+
+            begin
+              stderr = e.read_nonblock(chunk)
+              $stderr.write(stderr)
+            rescue IO::EAGAINWaitReadable, Errno::EIO, Errno::EAGAIN, Errno::EINTR => err
+              #_r, _w, _e = IO.select(process_fds, nil, process_fds, 0.5)
+              sleep 0.1
+            rescue EOFError => err
+            end
+          }
+
+          while s.alive?
+            #$stdout.write(".")
+
+            read_io.call
+
+            s.join(0.1)
+          end
+
+          read_io.call
+
+          return s.value.success?
+          #return exit_proc.call(o, e, s, false)
+
         when :async
           stdin, stdout, stderr, wait_thr = Open3.popen3(*cmd, options)
           return [stdin, stdout, stderr, wait_thr, exit_proc]