code: def test2NrtFeeds(self):
      values = []
      now = datetime.datetime.now()
      datetimes1 = [
          now + datetime.timedelta(seconds=i) for i in xrange(10)
      ]
      datetimes2 = [
          now + datetime.timedelta(seconds=i + len(datetimes1))
          for i in xrange(10)
      ]
      nrtFeed1 = NonRealtimeFeed(copy.copy(datetimes1))
      nrtFeed1.getEvent().subscribe(lambda x: values.append(x))
      nrtFeed2 = NonRealtimeFeed(copy.copy(datetimes2))
      nrtFeed2.getEvent().subscribe(lambda x: values.append(x))
  
      disp = dispatcher.Dispatcher()
      disp.addSubject(nrtFeed1)
      disp.addSubject(nrtFeed2)
      disp.run()
  
      self.assertEqual(len(values), len(datetimes1) + len(datetimes2))
      self.assertEqual(values[: len(datetimes1)], datetimes1)
      self.assertEqual(values[len(datetimes1) :], datetimes2)
  
imports: import datetime
  import copy
  from six.moves import xrange
  from .None import common
  from pyalgotrade import observer
  from pyalgotrade import dispatcher
label_desc: Use image node_id 2 for calling the DispatcherTestCase obj's underlying member method code with example usage: obj.test2NrtFeeds() without return types