code: def __init__(self, q, headers=None, *args, **kwargs):
      # Override to provide headers, which is in the standard API interface
      super(Streamer, self).__init__(*args, **kwargs)
  
      if headers:
          self.client.headers.update(headers)
  
      self.q = q
  
imports: from __future__ import absolute_import, division, print_function, unicode_literals
  import collections
  from datetime import datetime, timedelta
  import time
  import json
  import threading
  import oandapy
  import requests
  import backtrader
  from backtrader.metabase import MetaParams
  from backtrader.utils.py3 import queue, with_metaclass
  from backtrader.utils import AutoDict
label_desc: Use image node_id 1 to create a new Streamer object from inherited base classes: oandapy with example: obj = Streamer(q, headers)