code: def __init__(self, queue):
      super(Listener, self).__init__()
      self.__queue = queue
  
imports: import threading
  import json
  from six.moves import queue
  import tweepy
  from tweepy import streaming
  from pyalgotrade import observer
  import pyalgotrade.logger
label_desc: Use image node_id 1 to create a new Listener object from inherited base classes: streaming with example: obj = Listener(queue)