prompy.threadio package

prompy.threadio.pooled_caller module

class prompy.threadio.pooled_caller.PooledCaller(**pool_kwargs)

Bases: prompy.container.BasePromiseContainer

Class wrapper for urlcall. Auto-add calls to a PromiseQueuePool to be resolved.

__init__(**pool_kwargs)

Initialize self. See help(type(self)) for accurate signature.

add_promise(promise)

Add a promise to the container.

Parameters:promise (Promise[~PromiseReturnType]) – Returns:

call(url, **kwargs)

Return type:Promise[]

get(url, **kwargs)

head(url, **kwargs)

json_call(url, **kwargs)

post(url, **kwargs)

put(url, **kwargs)

prompy.threadio.promise_queue module

class prompy.threadio.promise_queue.PromiseQueue(start=False, max_idle=0.5, on_stop=None, queue_timeout=0.01, interval=0.01, daemon=False)

Bases: prompy.container.PromiseContainer

__init__(start=False, max_idle=0.5, on_stop=None, queue_timeout=0.01, interval=0.01, daemon=False)

Initialize self. See help(type(self)) for accurate signature.

add_promise(promise)

Add a promise to the container.

Parameters:promise (Promise[~PromiseReturnType]) – Returns:

cancel(cancel_id)

error

running

start()

stop()

class prompy.threadio.promise_queue.PromiseQueuePool(pool_size=8, start=False, max_idle=0.5, daemon=False)

Bases: prompy.container.BasePromiseRunner

__init__(pool_size=8, start=False, max_idle=0.5, daemon=False)

Initialize self. See help(type(self)) for accurate signature.

add_promise(promise)

Add a promise to the container.

Parameters:promise (Promise[~PromiseReturnType]) – Returns:

is_running()

on_thread_stop(func)

start()

stop()

prompy.threadio.tpromise module

Threaded Promise

Auto insert in a global thread pool.

Use the following environ vars:

• PROMPY_THREAD_POOL_SIZE=2
• PROMPY_THREAD_IDLE_TIME=0.5
• PROMPY_THREAD_DAEMON=false

class prompy.threadio.tpromise.TPromise(starter, *args, **kwargs)

Bases: prompy.promise.Promise

A promise with auto insert in a threadio.PromiseQueue.

__init__(starter, *args, **kwargs)

Promise takes at least a starter method with params to this promise resolve and reject. Does not call exec by default but with start_now the execution will be synchronous.

Parameters:

• starter – otherwise known as executor.
• then – initial resolve callback
• catch – initial catch callback
• complete – initial complete callback
• raise_again – raise the rejection error again.
• start_now –
• results_buffer_size – number of results to keep in the buffer.

classmethod stop_queue()

classmethod wrap(func)