def _get_stream(writer, config, limit=0): api = get_oauth_api(config) listener = PassThroughStreamListener(writer, limit=limit) return Stream(auth=api.auth, listener=listener)