code: def on_data(self, data):
      self.__queue.put(data)
      return True
  
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 4 for calling the Listener obj's underlying member method code with example usage: obj.on_data(data) and returns: True