← Back to branch summary

~conscioususer/polly/1.0

« back to all changes in this revision

Viewing changes to src/polly/twitter/realtime.py

  • Committer: Conscious User
  • Date: 2014-01-17 00:57:39 UTC
  • Revision ID: conscioususer@gmail.com-20140117005739-eww2bgwkzardbh1l
fix stream when first data is not friends list

Show diffs side-by-side

added added

removed removed

Lines of Context:
src/polly/twitter/realtime.py
415
415
                data, timestamp = self.queue.popleft()
416
416
 
417
417
                if buffer_starting:
418
 
                    for subdata in data:
419
 
                        self.account.shelf.set_friend(subdata)
420
 
 
421
 
                    del data[:]
422
 
 
423
 
                    self.open = True
424
 
 
425
 
                    self.account.identifier.set_spinning(False)
426
 
 
427
 
                    self.account.backend.release_connecting()
428
 
 
429
 
                    self.connected = True
430
 
 
431
 
                    print u'DEBUG: {} connected successfully'.format(self.account.get_user_nick())
432
 
 
433
 
                    self._acquire_update()
434
 
 
435
 
                    self.backup_notifier.notify()
436
 
 
437
 
                    self._release_update()
438
 
 
439
 
                    buffer_starting = False
 
418
                    if isinstance(data, list):
 
419
                        for subdata in data:
 
420
                            self.account.shelf.set_friend(subdata)
 
421
 
 
422
                        del data[:]
 
423
 
 
424
                        self.open = True
 
425
 
 
426
                        self.account.identifier.set_spinning(False)
 
427
 
 
428
                        self.account.backend.release_connecting()
 
429
 
 
430
                        self.connected = True
 
431
 
 
432
                        print u'DEBUG: {} connected successfully'.format(self.account.get_user_nick())
 
433
 
 
434
                        self._acquire_update()
 
435
 
 
436
                        self.backup_notifier.notify()
 
437
 
 
438
                        self._release_update()
 
439
 
 
440
                        buffer_starting = False
440
441
                else:
441
442
                    try:
442
443
                        keys = data.viewkeys()