'Stream data from the server: "stream <longpoll timeout ms>"'

def do_stream(self, line):

    args = self._parse(line, ['timeout'])
    timeout = 5000
    if ('timeout' in args):
        try:
            timeout = int(args['timeout'])
        except ValueError:
            print 'Timeout    must    be    in    milliseconds.'
            return
    reactor.callFromThread(self._do_event_stream, timeout)
