diff options
Diffstat (limited to 'vim/bundle/YouCompleteMe/third_party/requests-futures/test_requests_futures.py')
m--------- | vim/bundle/YouCompleteMe | 0 | ||||
-rw-r--r-- | vim/bundle/YouCompleteMe/third_party/requests-futures/test_requests_futures.py | 84 |
2 files changed, 0 insertions, 84 deletions
diff --git a/vim/bundle/YouCompleteMe b/vim/bundle/YouCompleteMe new file mode 160000 +Subproject 0de1c0c9bb13ce82172b472c676035cd47cf6a6 diff --git a/vim/bundle/YouCompleteMe/third_party/requests-futures/test_requests_futures.py b/vim/bundle/YouCompleteMe/third_party/requests-futures/test_requests_futures.py deleted file mode 100644 index b41836e..0000000 --- a/vim/bundle/YouCompleteMe/third_party/requests-futures/test_requests_futures.py +++ /dev/null @@ -1,84 +0,0 @@ -#!/usr/bin/env python -# -*- coding: utf-8 -*- - -"""Tests for Requests.""" - -from concurrent.futures import Future -from requests import Response -from os import environ -from requests_futures.sessions import FuturesSession -from unittest import TestCase, main - -HTTPBIN = environ.get('HTTPBIN_URL', 'http://httpbin.org/') - -def httpbin(*suffix): - """Returns url for HTTPBIN resource.""" - return HTTPBIN + '/'.join(suffix) - - -class RequestsTestCase(TestCase): - - def test_futures_session(self): - # basic futures get - sess = FuturesSession() - future = sess.get(httpbin('get')) - self.assertIsInstance(future, Future) - resp = future.result() - self.assertIsInstance(resp, Response) - self.assertEqual(200, resp.status_code) - - # non-200, 404 - future = sess.get(httpbin('status/404')) - resp = future.result() - self.assertEqual(404, resp.status_code) - - def cb(s, r): - self.assertIsInstance(s, FuturesSession) - self.assertIsInstance(r, Response) - # add the parsed json data to the response - r.data = r.json() - - future = sess.get(httpbin('get'), background_callback=cb) - # this should block until complete - resp = future.result() - self.assertEqual(200, resp.status_code) - # make sure the callback was invoked - self.assertTrue(hasattr(resp, 'data')) - - def rasing_cb(s, r): - raise Exception('boom') - - future = sess.get(httpbin('get'), background_callback=rasing_cb) - with self.assertRaises(Exception) as cm: - resp = future.result() - self.assertEqual('boom', cm.exception.args[0]) - - def test_max_workers(self): - """ Tests the `max_workers` shortcut. """ - from concurrent.futures import ThreadPoolExecutor - session = FuturesSession() - self.assertEqual(session.executor._max_workers, 2) - session = FuturesSession(max_workers=5) - self.assertEqual(session.executor._max_workers, 5) - session = FuturesSession(executor=ThreadPoolExecutor(max_workers=10)) - self.assertEqual(session.executor._max_workers, 10) - session = FuturesSession(executor=ThreadPoolExecutor(max_workers=10), - max_workers=5) - self.assertEqual(session.executor._max_workers, 10) - - def test_redirect(self): - """ Tests for the ability to cleanly handle redirects. """ - sess = FuturesSession() - future = sess.get(httpbin('redirect-to?url=get')) - self.assertIsInstance(future, Future) - resp = future.result() - self.assertIsInstance(resp, Response) - self.assertEqual(200, resp.status_code) - - future = sess.get(httpbin('redirect-to?url=status/404')) - resp = future.result() - self.assertEqual(404, resp.status_code) - - -if __name__ == '__main__': - main() |