code: def parse_skypipe_data_stream(msg, for_pipe):
      
      header = str(msg.pop(0))
      command = str(msg.pop(0))
      pipe_name = str(msg.pop(0))
      data = str(msg.pop(0))
      if header != SP_HEADER: return
      if pipe_name != for_pipe: return
      if command != SP_CMD_DATA: return
      if data == SP_DATA_EOF:
          raise EOFError()
      else:
          return data
docs: May return data from skypipe message or raises EOFError