code: def test_pipe_with_bytes(self):
      pipe = Pipe()
      pipe.write("∀∁∂∃∄∅".encode("utf8"))
      self.assertEqual(b"\xe2\x88", pipe.read(2))
      self.assertEqual(b"\x80\xe2\x88\x81", pipe.read(4))
      self.assertEqual(
          b"\xe2\x88\x82\xe2\x88\x83\xe2\x88", pipe.read(8)
      )
      self.assertEqual(b"\x84\xe2\x88\x85", pipe.read())
  
file_path: horovod/test/single/test_util.py
imports: import unittest
  from horovod.runner.util.streams import Pipe
  from horovod.runner.util.threads import in_thread
label_desc: Use image node_id 10 for calling the UtilTests obj's underlying member method code with example usage: obj.test_pipe_with_bytes() without return types