class_docstr: A file like object that publishes the stream to a 0MQ PUB socket.
  
  Output is handed off to an IO Thread
class_docstr_tok: ["A","file","like","object","that","publishes","the","stream","to","a","0MQ","PUB","socket",".","Output","is","handed","off","to","an","IO","Thread"]
docstr: schedule a flush in the IO thread
  
  call this on write, to indicate that flush should be called soon.
code: def _schedule_flush(self):
      """schedule a flush in the IO thread
  
      call this on write, to indicate that flush should be called soon.
      """
      if self._flush_pending:
          return
      self._flush_pending = True
  
      # add_timeout has to be handed to the io thread via event pipe
      def _schedule_in_thread():
          self._io_loop.call_later(self.flush_interval, self._flush)
  
      self.pub_thread.schedule(_schedule_in_thread)
  
imports: from __future__ import print_function
  import atexit
  from binascii import b2a_hex
  from collections import deque
  import os
  import sys
  import threading
  import warnings
  from io import StringIO, TextIOBase
  import zmq
  from zmq.eventloop.ioloop import IOLoop
  from zmq.eventloop.zmqstream import ZMQStream
  from jupyter_client.session import extract_header
  from ipython_genutils import py3compat
  from ipython_genutils.py3compat import unicode_type
label_desc: Use image node_id 6 for calling the OutStream obj's underlying member method code with example usage: obj._schedule_flush() without return types