futured 0.0

Functional interface for concurrent futures, including asynchronous I/O.

Futured provides a simple consistent interface for concurrent functional programming in Python. It can wrap any callable to return concurrent.futures.Future objects, and it can wrap any async coroutine to return asyncio.Future objects.

Usage

Transform any callable into one which runs in a thread or process pool, and returns a future.

from futured import threaded, processed
import requests

fetch = threaded(requests.Session().get)
fetch(url)  # returns Future

fs = (fetch(url + path) for path in paths)
fetch.results(fs)  # generates results in order
fetch.results(fs, timeout=None)  # generates results as completed

fetch.map(urls)  # generates results in order
fetch.map(urls, timeout=None)  # generates results as completed

Naturally futured wrappers can be used as decorators, but arguments can also be partially bound.

@threaded
def slow():
   ...

fetch = threaded(Session().get, url)
fetch(params=...)

The same interface works for aynscio.

from futured import asynced
import aiohttp

fetch = asynced(aiohttp.ClientSession().get)

Installation

$ pip install futured

Dependencies

• Python 3.4+

Tests

100% branch coverage.

$ pytest [--cov]