hybrid.core.Runnable.dispatch#

Runnable.dispatch(future, **kwargs)[source]#

Dispatch state from resolving future to either next or error methods.

Parameters:

state (concurrent.futures.Future-like object) – State future.

Returns state from next() or error(), or passes through an exception raised there.

Blocks on state resolution and execution of next() or error().