code: def makeConnection(self, protocol):
          
          self._errorState = None
  
          def cb(result):
              self.protocol = None
              if self._state == 'stopped':
                  # Don't transition to any other state. We are stopped.
                  pass
              else:
                  if isinstance(result, failure.Failure):
                      reason = result
                  else:
                      reason = None
                  self._toState('disconnected', reason)
  
          self.protocol = protocol
          d = protocol.deferred
          d.addBoth(cb)
docs: Called when the connection has been established.
  
          This method is called when an HTTP 200 response has been received,
          with the protocol that decodes the individual Twitter stream elements.
          That protocol will call the consumer for all Twitter entries received.
  
          The protocol, stored in L{protocol}, has a deferred that fires when
          the connection is closed, causing a transition to the
          C{'disconnected'} state.
  
          @param protocol: The Twitter stream protocol.
          @type protocol: L{TwitterStream}