Dependency injection is a popular software architecture pattern.
It’s main idea is that you provide Inversion of Control and can pass different things into your logic instead of hardcoding you stuff. And by doing this you are on your way to achieve Single Responsibility for your functions and objects.
A lot of programs we write rely on the context implicitly or explicitly. We can rely on configuration, env variables, stubs, logical dependencies, etc.
Let’s look at the example.
One of the most popular errors Python developers do in Django
is that they overuse settings
object inside the business logic.
This makes your logic framework-oriented
and hard to reason about in large projects.
Because values just pop out of nowhere in a deeply nested functions. And can be changed from the outside, from the context of your app.
Imagine that you have a django
based game,
where you award users with points
for each guessed letter in a word (unguessed letters are marked as '.'
):
from django.http import HttpRequest, HttpResponse
from words_app.logic import calculate_points
def view(request: HttpRequest) -> HttpResponse:
user_word: str = request.POST['word'] # just an example
points = calculate_points(user_word)
... # later you show the result to user somehow
# Somewhere in your `words_app/logic.py`:
def calculate_points(word: str) -> int:
guessed_letters_count = len([letter for letter in word if letter != '.'])
return _award_points_for_letters(guessed_letters_count)
def _award_points_for_letters(guessed: int) -> int:
return 0 if guessed < 5 else guessed # minimum 6 points possible!
Straight and simple!
But, later you decide to make the game more fun: let’s make the minimal accountable letters threshold configurable for an extra challenge.
You can just do it directly:
def _award_points_for_letters(guessed: int, threshold: int) -> int:
return 0 if guessed < threshold else guessed
And now your code won’t simply type-check. Because that’s how our caller looks like:
def calculate_points(word: str) -> int:
guessed_letters_count = len([letter for letter in word if letter != '.'])
return _award_points_for_letters(guessed_letters_count)
To fix this calculate_points
function
(and all other upper caller functions)
will have to accept threshold: int
as a parameter and pass it to _award_points_for_letters
.
Imagine that your large project has multiple things to configure in multiple functions. What a mess it would be!
Ok, you can directly use django.settings
(or similar)
in your _award_points_for_letters
function.
And ruin your pure logic with framework-specific details. That’s ugly!
We have learned that this tiny change showed us that it is not so easy to rely on implicit app context.
And instead of passing parameters for all callstack
or using dirty framework specific magic
you can use RequiresContext
container.
That was built just for this case.
Let’s see how our code changes:
from django.conf import settings
from django.http import HttpRequest, HttpResponse
from words_app.logic import calculate_points
def view(request: HttpRequest) -> HttpResponse:
user_word: str = request.POST['word'] # just an example
points = calculate_points(user_words)(settings) # passing the dependencies
... # later you show the result to user somehow
# Somewhere in your `words_app/logic.py`:
from typing import Protocol
from returns.context import RequiresContext
class _Deps(Protocol): # we rely on abstractions, not direct values or types
WORD_THRESHOLD: int
def calculate_points(word: str) -> RequiresContext[int, _Deps]:
guessed_letters_count = len([letter for letter in word if letter != '.'])
return _award_points_for_letters(guessed_letters_count)
def _award_points_for_letters(guessed: int) -> RequiresContext[int, _Deps]:
return RequiresContext(
lambda deps: 0 if guessed < deps.WORD_THRESHOLD else guessed,
)
And now you can pass your dependencies in a really direct and explicit way.
Let’s try to configure how we mark our unguessed letters
(previously unguessed letters were marked as '.'
).
Let’s say, we want to change this to be _
.
How can we do that with our existing function?
def calculate_points(word: str) -> RequiresContext[int, _Deps]:
guessed_letters_count = len([letter for letter in word if letter != '.'])
return _award_points_for_letters(guessed_letters_count)
We are already using RequiresContext
,
but its dependencies are just hidden from us!
We have a special helper for this case: .ask()
,
which returns us current dependencies.
The only thing we need to is to properly
annotate the type for our case: RequiresContext[int, _Deps].ask()
Sadly, currently mypy
is not able to infer the dependency type
out of the context and we need to explicitly provide it.
Let’s see the final result:
from returns.context import RequiresContext
class _Deps(Protocol): # we rely on abstractions, not direct values or types
WORD_THRESHOLD: int
UNGUESSED_CHAR: str
def calculate_points(word: str) -> RequiresContext[int, _Deps]:
def factory(deps: _Deps) -> RequiresContext[int, _Deps]:
guessed_letters_count = len([
letter for letter in word if letter != deps.UNGUESSED_CHAR
])
return _award_points_for_letters(guessed_letters_count)
return RequiresContext[int, _Deps].ask().bind(factory)
And now we access the current context from any place in our callstack. Isn’t it convenient?
Warning
RequiresContext
and similar types are not recursion safe.
If you would have nesting of more than sys.getrecursionlimit()
you will end up with RecursionError
.
Will this ever happen to you? Probably not.
The concept behind
RequiresContext
container is really simple.
It is a container around Callable[[EnvType], ReturnType]
function.
By its definition it works with pure functions that never fails.
It can be illustrated as a simple nested function:
>>> from typing import Callable
>>> def first(limit: int) -> Callable[[str], bool]:
... def inner(deps: str) -> bool:
... return len(deps) > limit
... return inner
>>> assert first(2)('abc') # first(limit)(deps)
>>> assert not first(5)('abc') # first(limit)(deps)
That’s basically enough to make dependency injection possible.
But how would you compose first
function?
Let’s say with the following function:
>>> def bool_to_str(arg: bool) -> str:
... return 'ok' if arg else 'nope'
It would be hard, knowing that it returns another function to be called later when the context is known.
We can wrap it in RequiresContext
container to allow better composition!
>>> from returns.context import RequiresContext
>>> def first(limit: int) -> RequiresContext[bool, str]:
... def inner(deps: str) -> bool:
... return len(deps) > limit
... return RequiresContext(inner) # wrapping function here!
>>> assert first(1).map(bool_to_str)('abc') == 'ok'
>>> assert first(5).map(bool_to_str)('abc') == 'nope'
There’s how execution flows:
RequiresContext execution flow.¶
The rule is: the dependencies are injected at the very last moment in time. And then normal logical execution happens.
RequiresContextResult
container
is a combination of RequiresContext[Result[a, b], env]
.
Which means that it is a wrapper around pure function that might fail.
We also added a lot of useful methods for this container, so you can work easily with it:
bind_result()
allows to bind functions that return Result
with just one call
bind_context()
allows to bind functions that return RequiresContext
easily
There are also several useful constructors from any possible type
Use it when you work with pure context-related functions that might fail.
RequiresContextIOResult
container
is a combination of RequiresContext[IOResult[a, b], env]
.
Which means that it is a wrapper around impure function that might fail.
We also added a lot of useful methods for this container, so you can work easily with it:
bind_result()
allows to bind functions that return Result
with just one call
bind_io()
allows to bind functions that return IO
with just one call
bind_ioresult()
allows to bind functions that return IOResult
with just one call
bind_context()
allows to bind functions that return RequiresContext
easily
bind_context_result()
allows to bind functions that return RequiresContextResult
easily
There are also several useful constructors from any possible type
Use it when you work with impure context-related functions that might fail. This is basically the main type that is going to be used in most apps.
RequiresContextFutureResult
container
is a combination of RequiresContext[FutureResult[a, b], env]
.
Which means that it is a wrapper around impure async function that might fail.
Here’s how it should be used:
1from typing import Final, Sequence, cast
2
3import anyio # you would need to `pip install anyio`
4import httpx # you would need to `pip install httpx`
5from typing_extensions import TypedDict
6
7from returns.context import RequiresContextFutureResultE
8from returns.functions import tap
9from returns.future import FutureResultE, future_safe
10from returns.iterables import Fold
11from returns.pipeline import managed
12from returns.result import ResultE, safe
13
14_URL: Final = 'https://jsonplaceholder.typicode.com/posts/{0}'
15
16
17class _Post(TypedDict):
18 id: int
19 user_id: int
20 title: str
21 body: str
22
23
24def _close(
25 client: httpx.AsyncClient,
26 raw_value: ResultE[Sequence[str]],
27) -> FutureResultE[None]:
28 return future_safe(client.aclose)()
29
30
31def _fetch_post(
32 post_id: int,
33) -> RequiresContextFutureResultE[_Post, httpx.AsyncClient]:
34 context: RequiresContextFutureResultE[
35 httpx.AsyncClient,
36 httpx.AsyncClient,
37 ] = RequiresContextFutureResultE.ask()
38
39 return context.bind_future_result(
40 lambda client: future_safe(client.get)(_URL.format(post_id)),
41 ).bind_result(
42 safe(tap(httpx.Response.raise_for_status)),
43 ).map(
44 lambda response: cast(_Post, response.json()), # or validate it
45 )
46
47
48def _show_titles(
49 number_of_posts: int,
50) -> RequiresContextFutureResultE[Sequence[str], httpx.AsyncClient]:
51 def factory(post: _Post) -> str:
52 return post['title']
53
54 titles = [
55 # Notice how easily we compose async and sync functions:
56 _fetch_post(post_id).map(factory)
57 # TODO: try `for post_id in (2, 1, 0):` to see how errors work
58 for post_id in range(1, number_of_posts + 1)
59 ]
60 return Fold.collect(titles, RequiresContextFutureResultE.from_value(()))
61
62
63if __name__ == '__main__':
64 # Let's fetch 3 titles of posts one-by-one, but with async client,
65 # because we want to highlight `managed` in this example:
66 managed_httpx = managed(_show_titles(3), _close)
67 future_result = managed_httpx(
68 FutureResultE.from_value(httpx.AsyncClient(timeout=5)),
69 )
70 print(anyio.run(future_result.awaitable)) # noqa: WPS421
71 # <IOResult: <Success: (
72 # 'sunt aut facere repellat provident occaecati ...',
73 # 'qui est esse',
74 # 'ea molestias quasi exercitationem repellat qui ipsa sit aut',
75 # )>>
This example illustrates the whole point of our actions: writing sync code that executes asynchronously without any magic at all!
We also added a lot of useful methods for this container, so you can work easily with it.
These methods are identical with RequiresContextIOResult
:
bind_result()
allows to bind functions that return Result
with just one call
bind_io()
allows to bind functions that return IO
with just one call
bind_ioresult()
allows to bind functions that return IOResult
with just one call
bind_future_result()
allows to bind functions that return FutureResult
with just one call
bind_context()
allows to bind functions that return RequiresContext
easily
bind_context_result()
allows to bind functions that return RequiresContextResult
easily
There are new ones:
bind_future()
allows to bind functions that return Future
container
bind_future_result()
allows to bind functions that return FutureResult
container
bind_async_future()
allows to bind async functions that return Future
container
bind_async_future_result()
allows to bind async functions that return FutureResult
container
bind_context_ioresult()
allows to bind functions that return RequiresContextIOResult
bind_async()
allows to bind async functions
that return RequiresContextFutureResult
container
bind_awaitable()
allows to bind async function that return raw values
Use it when you work with impure context-related functions that might fail. This is basically the main type that is going to be used in most apps.
There are several useful aliases for RequiresContext
and friends with some common values:
Reader
is an alias for RequiresContext[...]
to save you some typing.
Uses Reader
because it is a native name for this concept from Haskell.
RequiresContextResultE
is an alias for RequiresContextResult[..., Exception]
,
just use it when you want to work with RequiresContextResult
containers
that use exceptions as error type.
It is named ResultE
because it is ResultException
and ResultError
at the same time.
ReaderResult
is an alias for RequiresContextResult[...]
to save you some typing.
ReaderResultE
is an alias for RequiresContextResult[..., Exception]
RequiresContextIOResultE
is an alias for RequiresContextIOResult[..., Exception]
ReaderIOResult
is an alias for RequiresContextIOResult[...]
to save you some typing.
ReaderIOResultE
is an alias for RequiresContextIOResult[..., Exception]
RequiresContextFutureResultE
is an alias for RequiresContextFutureResult[..., Exception]
ReaderFutureResult
is an alias for RequiresContextFutureResult[...]
to save you some typing.
ReaderFutureResultE
is an alias for RequiresContextFutureResult[..., Exception]
RequiresContext
requires you to use one of the following methods:
from_value
when you have a raw value
from_requires_context_result
when you have RequiresContextResult
from_requires_context_ioresult
when you have RequiresContextIOResult
RequiresContextResult
requires you to use one of the following methods:
from_value
when you want to mark some raw value as a Success
from_failure
when you want to mark some raw value as a Failure
from_result
when you already have Result
container
from_context
when you have successful RequiresContext
from_failed_context
when you have failed RequiresContext
from_typecast
when you have RequiresContext[..., Result]
RequiresContextIOResult
requires you to use one of the following methods:
from_value
when you want to mark some raw value as a Success
from_failure
when you want to mark some raw value as a Failure
from_result
when you already have Result
container
from_io
when you have successful IO
container
from_failed_io
when you have failed IO
container
from_ioresult
when you already have IOResult
container
from_context
when you have successful RequiresContext
container
from_failed_context
when you have failed RequiresContext
container
from_result_context
when you have RequiresContextResult
container
from_typecast
when you have RequiresContext[..., IOResult]
RequiresContextFutureResult
requires
you to use one of the following methods:
from_value
when you want to mark some raw value as a Success
from_failure
when you want to mark some raw value as a Failure
from_result
when you already have Result
container
from_io
when you have successful IO
container
from_failed_io
when you have failed IO
container
from_ioresult
when you already have IOResult
container
from_future
when you already have successful Future
container
from_failed_future
when you already have failed Future
container
from_future_result
when you already have FutureResult
container
from_context
when you have successful RequiresContext
from_failed_context
when you have failed RequiresContext
from_result_context
when you have RequiresContextResult
container
from_ioresult_context
when you have RequiresContextIOResult
container
from_typecast
when you have RequiresContext[..., IOResult]
Use .ask()
method!
See this guide.
Yes, this container might remind a traditional decorator with arguments, let see an example:
>>> def example(print_result: bool):
... def decorator(function):
... def factory(*args, **kwargs):
... original = function(*args, **kwargs)
... if print_result:
... print(original)
... return original
... return factory
... return decorator
And it can be used like so:
>>> @example(print_result=True)
... def my_function(first: int, second: int) -> int:
... return first + second
>>> assert my_function(2, 3) == 5
5
We can model the similar idea with RequiresContext
:
>>> from returns.context import RequiresContext
>>> def my_function(first: int, second: int) -> RequiresContext[int, bool]:
... def factory(print_result: bool) -> int:
... original = first + second
... if print_result:
... print(original)
... return original
... return RequiresContext(factory)
>>> assert my_function(2, 3)(False) == 5
>>> assert my_function(2, 3)(True) == 5
5
As you can see,
it is easier to change the behaviour of a function with RequiresContext
.
While decorator with arguments glues values to a function forever.
Decide when you need which behaviour carefully.
We actually can! But, it is harder to write.
And RequiresContextResult
is actually
the very same thing as RequiresContext[Result, e]
, but has nicer API:
x: RequiresContext[Result[int, str], int]
x.map(lambda result: result.map(lambda number: number + 1))
# Is the same as:
y: RequiresContextResult[int, str, int]
y.map(lambda number: number + 1)
The second one looks better, doesn’t it?
The same applies for RequiresContextIOResult
and RequiresContextFutureResult
as well.
Because mypy
cannot possibly know the type of current context.
This is hard even for a plugin.
So, using this technique is better:
from returns.context import RequiresContext
def some_context(*args, **kwargs) -> RequiresContext[str, int]:
def factory(deps: int) -> RequiresContext[str, int]:
...
return RequiresContext[str, int].ask().bind(factory)
Dependency Injection pattern and
Inversion of Control
principle forms a lot of ideas and tooling
that do pretty much the same as RequiresContext
container.
What is the difference? Why do we need each of them?
Let’s find out! Tools like dependencies or punq tries to:
Inspect (by name or type respectively) function or class that needs dependencies
Build the required dependency tree from the source defined in the service container
There are other tools like inject
that also invades
your code with @inject
decorator.
RequiresContext
works completely different.
It respects your code and does not try to inspect in any manner.
It also does not care about building dependencies at all.
All it does is: provides simple API to compose functions that need additional context (or dependencies) to run.
You can even use them together: RequiresContext
will pass dependencies
built by punq
(or any other tool of your choice)
as a deps
parameter to RequiresContext
instance.
When to use which? Let’s dig into it!
RequiresContext
offers explicit context passing
for the whole function stack inside your program.
This means two things: you will have to pass it through all your code and
use it everywhere inside your program explicitly,
when you need to access the environment and dependencies
Traditional DI
allows to leave a lot
of code unaware of dependency injection.
Because you don’t have to maintain the context everywhere.
You just need to adjust your API to meet the dependency injector requirements.
On the other hand, you lose explicitness here.
So when to use RequiresContext
?
When you write pure functional code
When you want to know which code relies on context and which is free from it,
RequiresContext
makes this explicit and typed
When you rely on types inside your program
When you want to rely on functions rather than magic
When not to use RequiresContext
and use traditional DI?
When you already have a lot of code written in a different approach: in OOP and/or imperative styles
When you need to pass dependencies into a very deep level of your call stack implicitly (without modifying the whole stack), this is called magic
When you not rely on types for dependencies. There are cases when DI is made by names or tags
Here’s an example that might give you a better understanding of how
RequiresContext
is used on real and rather big projects:
from typing import Callable, Dict, Protocol, final
from returns.io import IOResultE
from returns.context import ReaderIOResultE
class _SyncPermissionsDeps(Protocol):
fetch_metadata: Callable[[], IOResultE['Metadata']]
get_user_permissions: Callable[['Metadata'], Dict[int, str]] # pure
update_bi_permissions: Callable[[Dict[int, str]], IOResultE['Payload']]
def sync_permissions() -> ReaderIOResultE[_SyncPermissionsDeps, 'Payload']:
"""
This functions runs a scheduled task once a day.
It syncs permissions from the metadata storage to our BI system.
"""
def factory(deps: _SyncPermissionsDeps) -> IOResultE['Payload']:
return deps.fetch_metadata().map(
deps.get_user_permissions,
).bind_ioresult(
deps.update_bi_permissions,
)
return ReaderIOResult(factory)
And then it is called like so:
# tasks.py
from celery import shared_task
from returns.functions import raise_exception
from logic.usecases.sync_permissions import sync_permissions
from infrastructure.implemented import Container
from infrastructure.services import bi
from infrastructure.repositories import db
@shared_task(autoretry_for=(ConnectionError,), max_retries=3)
def queue_sync_permissions():
# Building the container with dependencies to pass it into the context.
# We also make sure that we don't forget to raise internal exceptions
# and trigger celery retries.
return sync_permissions().alt(raise_exception)(Container(
fetch_metadata=db.select_user_metadata,
get_user_permissions=bi.permissions_from_user,
update_bi_permissions=bi.put_user_permissions,
))
Sometimes RequiresContext
and other similar types might be used with
no explicit dependencies so we need to have this type alias for Any.
Bases: BaseContainer
, SupportsKindN
[RequiresContext
, _ReturnType
, _EnvType
, NoReturn
], ReaderBased2
[_ReturnType
, _EnvType
]
The RequiresContext
container.
It’s main purpose is to wrap some specific function and to provide tools to compose other functions around it without actually calling it.
The RequiresContext
container passes the state
you want to share between functions.
Functions may read that state, but can’t change it.
The RequiresContext
container
lets us access shared immutable state within a specific context.
It can be used for lazy evaluation and typed dependency injection.
RequiresContext
is used with functions that never fail.
If you want to use RequiresContext
with returns Result
then consider using RequiresContextResult
instead.
Note
This container does not wrap ANY value. It wraps only functions. You won’t be able to supply arbitrary types!
See also
inner_value (Callable
[[TypeVar
(_EnvType
, contravariant=True)], TypeVar
(_ReturnType
, covariant=True)]) –
A convenient placeholder to call methods created by .from_value():
Allows to compose functions inside the wrapped container.
Here’s how it works:
>>> from returns.context import RequiresContext
>>> def first(lg: bool) -> RequiresContext[int, float]:
... # `deps` has `float` type here:
... return RequiresContext(
... lambda deps: deps if lg else -deps,
... )
>>> assert first(True).map(lambda number: number * 10)(2.5) == 25.0
>>> assert first(False).map(lambda number: number * 10)(0.1) -1.0
function (Callable
[[TypeVar
(_ReturnType
, covariant=True)], TypeVar
(_NewReturnType
)]) –
RequiresContext
[TypeVar
(_NewReturnType
), TypeVar
(_EnvType
, contravariant=True)]
Calls a wrapped function in a container on this container.
>>> from returns.context import RequiresContext
>>> assert RequiresContext.from_value('a').apply(
... RequiresContext.from_value(lambda inner: inner + 'b')
... )(...) == 'ab'
container (KindN
[RequiresContext
, Callable
[[TypeVar
(_ReturnType
, covariant=True)], TypeVar
(_NewReturnType
)], TypeVar
(_EnvType
, contravariant=True), Any
]) –
RequiresContext
[TypeVar
(_NewReturnType
), TypeVar
(_EnvType
, contravariant=True)]
Composes a container with a function returning another container.
This is useful when you do several computations that rely on the same context.
>>> from returns.context import RequiresContext
>>> def first(lg: bool) -> RequiresContext[int, float]:
... # `deps` has `float` type here:
... return RequiresContext(
... lambda deps: deps if lg else -deps,
... )
>>> def second(number: int) -> RequiresContext[str, float]:
... # `deps` has `float` type here:
... return RequiresContext(
... lambda deps: '>=' if number >= deps else '<',
... )
>>> assert first(True).bind(second)(1) == '>='
>>> assert first(False).bind(second)(2) == '<'
function (Callable
[[TypeVar
(_ReturnType
, covariant=True)], KindN
[RequiresContext
, TypeVar
(_NewReturnType
), TypeVar
(_EnvType
, contravariant=True), Any
]]) –
RequiresContext
[TypeVar
(_NewReturnType
), TypeVar
(_EnvType
, contravariant=True)]
Alias for bind_context method, it is the same as bind here.
function (Callable
[[TypeVar
(_ReturnType
, covariant=True)], KindN
[RequiresContext
, TypeVar
(_NewReturnType
), TypeVar
(_EnvType
, contravariant=True), Any
]]) –
RequiresContext
[TypeVar
(_NewReturnType
), TypeVar
(_EnvType
, contravariant=True)]
Allows to modify the environment type.
>>> from returns.context import RequiresContext
>>> def mul(arg: int) -> RequiresContext[float, int]:
... return RequiresContext(lambda deps: arg * deps)
>>> assert mul(3).modify_env(int)('2') == 6
function (Callable
[[TypeVar
(_NewEnvType
)], TypeVar
(_EnvType
, contravariant=True)]) –
RequiresContext
[TypeVar
(_ReturnType
, covariant=True), TypeVar
(_NewEnvType
)]
Get current context to use the dependencies.
It is a common scenario when you need to use the environment.
For example, you want to do some context-related computation,
but you don’t have the context instance at your disposal.
That’s where .ask()
becomes useful!
>>> from typing_extensions import TypedDict
>>> class Deps(TypedDict):
... message: str
>>> def first(lg: bool) -> RequiresContext[int, Deps]:
... # `deps` has `Deps` type here:
... return RequiresContext(
... lambda deps: deps['message'] if lg else 'error',
... )
>>> def second(text: str) -> RequiresContext[int, Deps]:
... return first(len(text) > 3)
>>> assert second('abc')({'message': 'ok'}) == 'error'
>>> assert second('abcd')({'message': 'ok'}) == 'ok'
And now imagine that you have to change this 3
limit.
And you want to be able to set it via environment as well.
Ok, let’s fix it with the power of RequiresContext.ask()
!
>>> from typing_extensions import TypedDict
>>> class Deps(TypedDict):
... message: str
... limit: int # note this new field!
>>> def new_first(lg: bool) -> RequiresContext[int, Deps]:
... # `deps` has `Deps` type here:
... return RequiresContext(
... lambda deps: deps['message'] if lg else 'err',
... )
>>> def new_second(text: str) -> RequiresContext[int, Deps]:
... return RequiresContext[int, Deps].ask().bind(
... lambda deps: new_first(len(text) > deps.get('limit', 3)),
... )
>>> assert new_second('abc')({'message': 'ok', 'limit': 2}) == 'ok'
>>> assert new_second('abcd')({'message': 'ok'}) == 'ok'
>>> assert new_second('abcd')({'message': 'ok', 'limit': 5}) == 'err'
That’s how ask
works.
This class contains methods that require to explicitly set type annotations. Why? Because it is impossible to figure out the type without them. So, here’s how you should use them:
RequiresContext[int, Dict[str, str]].ask()
Otherwise, your .ask()
method
will return RequiresContext[<nothing>, <nothing>]
,
which is unusable:
env = RequiresContext.ask()
env(some_deps)
And mypy
will warn you: error: Need type annotation for '...'
:rtype: RequiresContext
[TypeVar
(_EnvType
, contravariant=True), TypeVar
(_EnvType
, contravariant=True)]
Used to return some specific value from the container.
Consider this method as some kind of factory.
Passed value will be a return type.
Make sure to use no_args
for getting the unit value.
>>> from returns.context import RequiresContext
>>> unit = RequiresContext.from_value(5)
>>> assert unit(RequiresContext.no_args) == 5
Might be used with or without direct type hint.
inner_value (TypeVar
(_FirstType
)) –
RequiresContext
[TypeVar
(_FirstType
), Any
]
Used to create new containers from existing ones.
Used as a part of ReaderBased2
interface.
>>> from returns.context import RequiresContext
>>> unit = RequiresContext.from_value(5)
>>> assert RequiresContext.from_context(unit)(...) == unit(...)
inner_value (RequiresContext
[TypeVar
(_NewReturnType
), TypeVar
(_NewEnvType
)]) –
RequiresContext
[TypeVar
(_NewReturnType
), TypeVar
(_NewEnvType
)]
Typecasts RequiresContextResult
to RequiresContext
instance.
Breaks RequiresContextResult[a, b, e]
into RequiresContext[Result[a, b], e]
.
>>> from returns.context import RequiresContext
>>> from returns.context import RequiresContextResult
>>> from returns.result import Success
>>> assert RequiresContext.from_requires_context_result(
... RequiresContextResult.from_value(1),
... )(...) == Success(1)
Can be reverted with RequiresContextResult.from_typecast
.
inner_value (RequiresContextResult
[TypeVar
(_ValueType
), TypeVar
(_ErrorType
), TypeVar
(_EnvType
, contravariant=True)]) –
RequiresContext
[Result
[TypeVar
(_ValueType
), TypeVar
(_ErrorType
)], TypeVar
(_EnvType
, contravariant=True)]
Typecasts RequiresContextIOResult
to RequiresContext
instance.
Breaks RequiresContextIOResult[a, b, e]
into RequiresContext[IOResult[a, b], e]
.
>>> from returns.context import RequiresContext
>>> from returns.context import RequiresContextIOResult
>>> from returns.io import IOSuccess
>>> assert RequiresContext.from_requires_context_ioresult(
... RequiresContextIOResult.from_value(1),
... )(...) == IOSuccess(1)
Can be reverted with RequiresContextIOResult.from_typecast
.
inner_value (RequiresContextIOResult
[TypeVar
(_ValueType
), TypeVar
(_ErrorType
), TypeVar
(_EnvType
, contravariant=True)]) –
RequiresContext
[IOResult
[TypeVar
(_ValueType
), TypeVar
(_ErrorType
)], TypeVar
(_EnvType
, contravariant=True)]
Typecasts RequiresContextIOResult
to RequiresContext
instance.
Breaks RequiresContextIOResult[a, b, e]
into RequiresContext[IOResult[a, b], e]
.
>>> import anyio
>>> from returns.context import RequiresContext
>>> from returns.context import RequiresContextFutureResult
>>> from returns.io import IOSuccess
>>> container = RequiresContext.from_requires_context_future_result(
... RequiresContextFutureResult.from_value(1),
... )
>>> assert anyio.run(
... container, RequiresContext.no_args,
... ) == IOSuccess(1)
Can be reverted with RequiresContextFutureResult.from_typecast
.
inner_value (RequiresContextFutureResult
[TypeVar
(_ValueType
), TypeVar
(_ErrorType
), TypeVar
(_EnvType
, contravariant=True)]) –
RequiresContext
[FutureResult
[TypeVar
(_ValueType
), TypeVar
(_ErrorType
)], TypeVar
(_EnvType
, contravariant=True)]
Sometimes RequiresContext is too long to type.
inner_value (Callable
[[TypeVar
(_EnvType
, contravariant=True)], TypeVar
(_ReturnType
, covariant=True)]) –
Bases: BaseContainer
, SupportsKindN
[RequiresContextResult
, _ValueType
, _ErrorType
, _EnvType
], ReaderResultBasedN
[_ValueType
, _ErrorType
, _EnvType
]
The RequiresContextResult
combinator.
See returns.context.requires_context.RequiresContext
for more docs.
This is just a handy wrapper around RequiresContext[Result[a, b], env]
which represents a context-dependent pure operation
that might fail and return returns.result.Result
.
It has several important differences from the regular Result
classes.
It does not have Success
and Failure
subclasses.
Because, the computation is not yet performed.
And we cannot know the type in advance.
So, this is a thin wrapper, without any changes in logic.
Why do we need this wrapper? That’s just for better usability!
>>> from returns.context import RequiresContext
>>> from returns.result import Success, Result
>>> def function(arg: int) -> Result[int, str]:
... return Success(arg + 1)
>>> # Without wrapper:
>>> assert RequiresContext.from_value(Success(1)).map(
... lambda result: result.bind(function),
... )(...) == Success(2)
>>> # With wrapper:
>>> assert RequiresContextResult.from_value(1).bind_result(
... function,
... )(...) == Success(2)
This way RequiresContextResult
allows to simply work with:
raw values and pure functions
RequiresContext
values and pure functions returning it
Result
and functions returning it
Important implementation details
Due it is meaning, RequiresContextResult
cannot have Success
and Failure
subclasses.
We only have just one type. That’s by design.
Different converters are also not supported for this type.
Use converters inside the RequiresContext
context, not outside.
See also
inner_value (Callable
[[TypeVar
(_EnvType
, contravariant=True)], Result
[TypeVar
(_ValueType
, covariant=True), TypeVar
(_ErrorType
, covariant=True)]]) –
A convenient placeholder to call methods created by .from_value().
Swaps value and error types.
So, values become errors and errors become values.
It is useful when you have to work with errors a lot.
And since we have a lot of .bind_
related methods
and only a single .lash
- it is easier to work with values.
>>> from returns.context import RequiresContextResult
>>> from returns.result import Failure, Success
>>> success = RequiresContextResult.from_value(1)
>>> failure = RequiresContextResult.from_failure(1)
>>> assert success.swap()(...) == Failure(1)
>>> assert failure.swap()(...) == Success(1)
RequiresContextResult
[TypeVar
(_ErrorType
, covariant=True), TypeVar
(_ValueType
, covariant=True), TypeVar
(_EnvType
, contravariant=True)]
Composes successful container with a pure function.
>>> from returns.context import RequiresContextResult
>>> from returns.result import Success, Failure
>>> assert RequiresContextResult.from_value(1).map(
... lambda x: x + 1,
... )(...) == Success(2)
>>> assert RequiresContextResult.from_failure(1).map(
... lambda x: x + 1,
... )(...) == Failure(1)
function (Callable
[[TypeVar
(_ValueType
, covariant=True)], TypeVar
(_NewValueType
)]) –
RequiresContextResult
[TypeVar
(_NewValueType
), TypeVar
(_ErrorType
, covariant=True), TypeVar
(_EnvType
, contravariant=True)]
Calls a wrapped function in a container on this container.
>>> from returns.context import RequiresContextResult
>>> from returns.result import Failure, Success
>>> def transform(arg: str) -> str:
... return arg + 'b'
>>> assert RequiresContextResult.from_value('a').apply(
... RequiresContextResult.from_value(transform),
... )(...) == Success('ab')
>>> assert RequiresContextResult.from_failure('a').apply(
... RequiresContextResult.from_value(transform),
... )(...) == Failure('a')
>>> assert isinstance(RequiresContextResult.from_value('a').apply(
... RequiresContextResult.from_failure(transform),
... )(...), Failure) is True
container (KindN
[RequiresContextResult
, Callable
[[TypeVar
(_ValueType
, covariant=True)], TypeVar
(_NewValueType
)], TypeVar
(_ErrorType
, covariant=True), TypeVar
(_EnvType
, contravariant=True)]) –
RequiresContextResult
[TypeVar
(_NewValueType
), TypeVar
(_ErrorType
, covariant=True), TypeVar
(_EnvType
, contravariant=True)]
Composes this container with a function returning the same type.
>>> from returns.context import RequiresContextResult
>>> from returns.result import Success, Failure
>>> def first(lg: bool) -> RequiresContextResult[int, int, float]:
... # `deps` has `float` type here:
... return RequiresContextResult(
... lambda deps: Success(deps) if lg else Failure(-deps),
... )
>>> def second(
... number: int,
... ) -> RequiresContextResult[str, int, float]:
... # `deps` has `float` type here:
... return RequiresContextResult(
... lambda deps: Success('>=' if number >= deps else '<'),
... )
>>> assert first(True).bind(second)(1) == Success('>=')
>>> assert first(False).bind(second)(2) == Failure(-2)
function (Callable
[[TypeVar
(_ValueType
, covariant=True)], KindN
[RequiresContextResult
, TypeVar
(_NewValueType
), TypeVar
(_ErrorType
, covariant=True), TypeVar
(_EnvType
, contravariant=True)]]) –
RequiresContextResult
[TypeVar
(_NewValueType
), TypeVar
(_ErrorType
, covariant=True), TypeVar
(_EnvType
, contravariant=True)]
Alias for bind_context_result method, it is the same as bind here.
function (Callable
[[TypeVar
(_ValueType
, covariant=True)], KindN
[RequiresContextResult
, TypeVar
(_NewValueType
), TypeVar
(_ErrorType
, covariant=True), TypeVar
(_EnvType
, contravariant=True)]]) –
RequiresContextResult
[TypeVar
(_NewValueType
), TypeVar
(_ErrorType
, covariant=True), TypeVar
(_EnvType
, contravariant=True)]
Binds Result
returning function to current container.
>>> from returns.context import RequiresContextResult
>>> from returns.result import Success, Failure, Result
>>> def function(num: int) -> Result[str, int]:
... return Success(num + 1) if num > 0 else Failure('<0')
>>> assert RequiresContextResult.from_value(1).bind_result(
... function,
... )(RequiresContextResult.no_args) == Success(2)
>>> assert RequiresContextResult.from_value(0).bind_result(
... function,
... )(RequiresContextResult.no_args) == Failure('<0')
>>> assert RequiresContextResult.from_failure(':(').bind_result(
... function,
... )(RequiresContextResult.no_args) == Failure(':(')
function (Callable
[[TypeVar
(_ValueType
, covariant=True)], Result
[TypeVar
(_NewValueType
), TypeVar
(_ErrorType
, covariant=True)]]) –
RequiresContextResult
[TypeVar
(_NewValueType
), TypeVar
(_ErrorType
, covariant=True), TypeVar
(_EnvType
, contravariant=True)]
Binds RequiresContext
returning function to current container.
>>> from returns.context import RequiresContext
>>> from returns.result import Success, Failure
>>> def function(arg: int) -> RequiresContext[int, str]:
... return RequiresContext(lambda deps: len(deps) + arg)
>>> assert function(2)('abc') == 5
>>> assert RequiresContextResult.from_value(2).bind_context(
... function,
... )('abc') == Success(5)
>>> assert RequiresContextResult.from_failure(2).bind_context(
... function,
... )('abc') == Failure(2)
function (Callable
[[TypeVar
(_ValueType
, covariant=True)], RequiresContext
[TypeVar
(_NewValueType
), TypeVar
(_EnvType
, contravariant=True)]]) –
RequiresContextResult
[TypeVar
(_NewValueType
), TypeVar
(_ErrorType
, covariant=True), TypeVar
(_EnvType
, contravariant=True)]
Composes failed container with a pure function.
>>> from returns.context import RequiresContextResult
>>> from returns.result import Success, Failure
>>> assert RequiresContextResult.from_value(1).alt(
... lambda x: x + 1,
... )(...) == Success(1)
>>> assert RequiresContextResult.from_failure(1).alt(
... lambda x: x + 1,
... )(...) == Failure(2)
function (Callable
[[TypeVar
(_ErrorType
, covariant=True)], TypeVar
(_NewErrorType
)]) –
RequiresContextResult
[TypeVar
(_ValueType
, covariant=True), TypeVar
(_NewErrorType
), TypeVar
(_EnvType
, contravariant=True)]
Composes this container with a function returning the same type.
>>> from returns.context import RequiresContextResult
>>> from returns.result import Success, Failure
>>> def lashable(arg: str) -> RequiresContextResult[str, str, str]:
... if len(arg) > 1:
... return RequiresContextResult(
... lambda deps: Success(deps + arg),
... )
... return RequiresContextResult(
... lambda deps: Failure(arg + deps),
... )
>>> assert RequiresContextResult.from_value('a').lash(
... lashable,
... )('c') == Success('a')
>>> assert RequiresContextResult.from_failure('a').lash(
... lashable,
... )('c') == Failure('ac')
>>> assert RequiresContextResult.from_failure('aa').lash(
... lashable,
... )('b') == Success('baa')
function (Callable
[[TypeVar
(_ErrorType
, covariant=True)], KindN
[RequiresContextResult
, TypeVar
(_ValueType
, covariant=True), TypeVar
(_NewErrorType
), TypeVar
(_EnvType
, contravariant=True)]]) –
RequiresContextResult
[TypeVar
(_ValueType
, covariant=True), TypeVar
(_NewErrorType
), TypeVar
(_EnvType
, contravariant=True)]
Allows to modify the environment type.
>>> from returns.context import RequiresContextResultE
>>> from returns.result import Success, safe
>>> def div(arg: int) -> RequiresContextResultE[float, int]:
... return RequiresContextResultE(
... safe(lambda deps: arg / deps),
... )
>>> assert div(3).modify_env(int)('2') == Success(1.5)
>>> assert div(3).modify_env(int)('0').failure()
function (Callable
[[TypeVar
(_NewEnvType
)], TypeVar
(_EnvType
, contravariant=True)]) –
RequiresContextResult
[TypeVar
(_ValueType
, covariant=True), TypeVar
(_ErrorType
, covariant=True), TypeVar
(_NewEnvType
)]
Is used to get the current dependencies inside the call stack.
Similar to returns.context.requires_context.RequiresContext.ask()
,
but returns Result
instead of a regular value.
Please, refer to the docs there to learn how to use it.
One important note that is worth duplicating here:
you might need to provide _EnvType
explicitly,
so mypy
will know about it statically.
>>> from returns.context import RequiresContextResultE
>>> from returns.result import Success
>>> assert RequiresContextResultE[int, int].ask().map(
... str,
... )(1) == Success('1')
RequiresContextResult
[TypeVar
(_EnvType
, contravariant=True), TypeVar
(_ErrorType
, covariant=True), TypeVar
(_EnvType
, contravariant=True)]
Creates new container with Result
as a unit value.
>>> from returns.context import RequiresContextResult
>>> from returns.result import Success, Failure
>>> deps = RequiresContextResult.no_args
>>> assert RequiresContextResult.from_result(
... Success(1),
... )(deps) == Success(1)
>>> assert RequiresContextResult.from_result(
... Failure(1),
... )(deps) == Failure(1)
inner_value (Result
[TypeVar
(_NewValueType
), TypeVar
(_NewErrorType
)]) –
RequiresContextResult
[TypeVar
(_NewValueType
), TypeVar
(_NewErrorType
), Any
]
You might end up with RequiresContext[Result[...]]
as a value.
This method is designed to turn it into RequiresContextResult
.
It will save all the typing information.
It is just more useful!
>>> from returns.context import RequiresContext
>>> from returns.result import Success, Failure
>>> assert RequiresContextResult.from_typecast(
... RequiresContext.from_value(Success(1)),
... )(RequiresContextResult.no_args) == Success(1)
>>> assert RequiresContextResult.from_typecast(
... RequiresContext.from_value(Failure(1)),
... )(RequiresContextResult.no_args) == Failure(1)
inner_value (RequiresContext
[Result
[TypeVar
(_NewValueType
), TypeVar
(_NewErrorType
)], TypeVar
(_EnvType
, contravariant=True)]) –
RequiresContextResult
[TypeVar
(_NewValueType
), TypeVar
(_NewErrorType
), TypeVar
(_EnvType
, contravariant=True)]
Creates new container from RequiresContext
as a success unit.
>>> from returns.context import RequiresContext
>>> from returns.result import Success
>>> assert RequiresContextResult.from_context(
... RequiresContext.from_value(1),
... )(...) == Success(1)
inner_value (RequiresContext
[TypeVar
(_NewValueType
), TypeVar
(_NewEnvType
)]) –
RequiresContextResult
[TypeVar
(_NewValueType
), Any
, TypeVar
(_NewEnvType
)]
Creates new container from RequiresContext
as a failure unit.
>>> from returns.context import RequiresContext
>>> from returns.result import Failure
>>> assert RequiresContextResult.from_failed_context(
... RequiresContext.from_value(1),
... )(...) == Failure(1)
inner_value (RequiresContext
[TypeVar
(_NewValueType
), TypeVar
(_NewEnvType
)]) –
RequiresContextResult
[Any
, TypeVar
(_NewValueType
), TypeVar
(_NewEnvType
)]
Creates RequiresContextResult
from another instance of it.
>>> from returns.context import ReaderResult
>>> from returns.result import Success, Failure
>>> assert ReaderResult.from_result_context(
... ReaderResult.from_value(1),
... )(...) == Success(1)
>>> assert ReaderResult.from_result_context(
... ReaderResult.from_failure(1),
... )(...) == Failure(1)
inner_value (RequiresContextResult
[TypeVar
(_NewValueType
), TypeVar
(_NewErrorType
), TypeVar
(_NewEnvType
)]) –
RequiresContextResult
[TypeVar
(_NewValueType
), TypeVar
(_NewErrorType
), TypeVar
(_NewEnvType
)]
Creates new container with Success(inner_value)
as a unit value.
>>> from returns.context import RequiresContextResult
>>> from returns.result import Success
>>> assert RequiresContextResult.from_value(1)(...) == Success(1)
inner_value (TypeVar
(_FirstType
)) –
RequiresContextResult
[TypeVar
(_FirstType
), Any
, Any
]
Creates new container with Failure(inner_value)
as a unit value.
>>> from returns.context import RequiresContextResult
>>> from returns.result import Failure
>>> assert RequiresContextResult.from_failure(1)(...) == Failure(1)
inner_value (TypeVar
(_FirstType
)) –
RequiresContextResult
[Any
, TypeVar
(_FirstType
), Any
]
Alias for a popular case when Result
has Exception
as error type.
alias of RequiresContextResult
[_ValueType
, Exception
, _EnvType
]
Alias to save you some typing. Uses original name from Haskell.
inner_value (Callable
[[TypeVar
(_EnvType
, contravariant=True)], Result
[TypeVar
(_ValueType
, covariant=True), TypeVar
(_ErrorType
, covariant=True)]]) –
Alias to save you some typing. Has Exception
as error type.
alias of RequiresContextResult
[_ValueType
, Exception
, _EnvType
]
Bases: BaseContainer
, SupportsKindN
[RequiresContextIOResult
, _ValueType
, _ErrorType
, _EnvType
], ReaderIOResultBasedN
[_ValueType
, _ErrorType
, _EnvType
]
The RequiresContextIOResult
combinator.
See returns.context.requires_context.RequiresContext
and returns.context.requires_context_result.RequiresContextResult
for more docs.
This is just a handy wrapper around
RequiresContext[IOResult[a, b], env]
which represents a context-dependent impure operation that might fail.
It has several important differences from the regular Result
classes.
It does not have Success
and Failure
subclasses.
Because, the computation is not yet performed.
And we cannot know the type in advance.
So, this is a thin wrapper, without any changes in logic.
Why do we need this wrapper? That’s just for better usability!
>>> from returns.context import RequiresContext
>>> from returns.io import IOSuccess, IOResult
>>> def function(arg: int) -> IOResult[int, str]:
... return IOSuccess(arg + 1)
>>> # Without wrapper:
>>> assert RequiresContext.from_value(IOSuccess(1)).map(
... lambda ioresult: ioresult.bind(function),
... )(...) == IOSuccess(2)
>>> # With wrapper:
>>> assert RequiresContextIOResult.from_value(1).bind_ioresult(
... function,
... )(...) == IOSuccess(2)
This way RequiresContextIOResult
allows to simply work with:
raw values and pure functions
RequiresContext
values and pure functions returning it
RequiresContextResult
values and pure functions returning it
Result
and pure functions returning it
IOResult
and functions returning it
other RequiresContextIOResult
related functions and values
This is a complex type for complex tasks!
Important implementation details
Due it is meaning, RequiresContextIOResult
cannot have Success
and Failure
subclasses.
We only have just one type. That’s by design.
Different converters are also not supported for this type.
Use converters inside the RequiresContext
context, not outside.
See also
inner_value (Callable
[[TypeVar
(_EnvType
, contravariant=True)], IOResult
[TypeVar
(_ValueType
, covariant=True), TypeVar
(_ErrorType
)]]) –
A convenient placeholder to call methods created by .from_value().
Swaps value and error types.
So, values become errors and errors become values.
It is useful when you have to work with errors a lot.
And since we have a lot of .bind_
related methods
and only a single .lash
- it is easier to work with values.
>>> from returns.context import RequiresContextIOResult
>>> from returns.io import IOSuccess, IOFailure
>>> success = RequiresContextIOResult.from_value(1)
>>> failure = RequiresContextIOResult.from_failure(1)
>>> assert success.swap()(...) == IOFailure(1)
>>> assert failure.swap()(...) == IOSuccess(1)
RequiresContextIOResult
[TypeVar
(_ErrorType
), TypeVar
(_ValueType
, covariant=True), TypeVar
(_EnvType
, contravariant=True)]
Composes successful container with a pure function.
>>> from returns.context import RequiresContextIOResult
>>> from returns.io import IOSuccess, IOFailure
>>> assert RequiresContextIOResult.from_value(1).map(
... lambda x: x + 1,
... )(...) == IOSuccess(2)
>>> assert RequiresContextIOResult.from_failure(1).map(
... lambda x: x + 1,
... )(...) == IOFailure(1)
function (Callable
[[TypeVar
(_ValueType
, covariant=True)], TypeVar
(_NewValueType
)]) –
RequiresContextIOResult
[TypeVar
(_NewValueType
), TypeVar
(_ErrorType
), TypeVar
(_EnvType
, contravariant=True)]
Calls a wrapped function in a container on this container.
>>> from returns.context import RequiresContextIOResult
>>> from returns.io import IOSuccess, IOFailure
>>> def transform(arg: str) -> str:
... return arg + 'b'
>>> assert RequiresContextIOResult.from_value('a').apply(
... RequiresContextIOResult.from_value(transform),
... )(...) == IOSuccess('ab')
>>> assert RequiresContextIOResult.from_value('a').apply(
... RequiresContextIOResult.from_failure(1),
... )(...) == IOFailure(1)
>>> assert RequiresContextIOResult.from_failure('a').apply(
... RequiresContextIOResult.from_value(transform),
... )(...) == IOFailure('a')
>>> assert RequiresContextIOResult.from_failure('a').apply(
... RequiresContextIOResult.from_failure('b'),
... )(...) == IOFailure('a')
container (KindN
[RequiresContextIOResult
, Callable
[[TypeVar
(_ValueType
, covariant=True)], TypeVar
(_NewValueType
)], TypeVar
(_ErrorType
), TypeVar
(_EnvType
, contravariant=True)]) –
RequiresContextIOResult
[TypeVar
(_NewValueType
), TypeVar
(_ErrorType
), TypeVar
(_EnvType
, contravariant=True)]
Composes this container with a function returning the same type.
>>> from returns.context import RequiresContextIOResult
>>> from returns.io import IOSuccess, IOFailure
>>> def first(lg: bool) -> RequiresContextIOResult[int, int, float]:
... # `deps` has `float` type here:
... return RequiresContextIOResult(
... lambda deps: IOSuccess(deps) if lg else IOFailure(-deps),
... )
>>> def second(
... number: int,
... ) -> RequiresContextIOResult[str, int, float]:
... # `deps` has `float` type here:
... return RequiresContextIOResult(
... lambda deps: IOSuccess('>=' if number >= deps else '<'),
... )
>>> assert first(True).bind(second)(1) == IOSuccess('>=')
>>> assert first(False).bind(second)(2) == IOFailure(-2)
function (Callable
[[TypeVar
(_ValueType
, covariant=True)], KindN
[RequiresContextIOResult
, TypeVar
(_NewValueType
), TypeVar
(_ErrorType
), TypeVar
(_EnvType
, contravariant=True)]]) –
RequiresContextIOResult
[TypeVar
(_NewValueType
), TypeVar
(_ErrorType
), TypeVar
(_EnvType
, contravariant=True)]
Alias for bind_context_ioresult method, it is the same as bind here.
function (Callable
[[TypeVar
(_ValueType
, covariant=True)], KindN
[RequiresContextIOResult
, TypeVar
(_NewValueType
), TypeVar
(_ErrorType
), TypeVar
(_EnvType
, contravariant=True)]]) –
RequiresContextIOResult
[TypeVar
(_NewValueType
), TypeVar
(_ErrorType
), TypeVar
(_EnvType
, contravariant=True)]
Binds Result
returning function to the current container.
>>> from returns.context import RequiresContextIOResult
>>> from returns.result import Failure, Result, Success
>>> from returns.io import IOSuccess, IOFailure
>>> def function(num: int) -> Result[int, str]:
... return Success(num + 1) if num > 0 else Failure('<0')
>>> assert RequiresContextIOResult.from_value(1).bind_result(
... function,
... )(RequiresContextIOResult.no_args) == IOSuccess(2)
>>> assert RequiresContextIOResult.from_value(0).bind_result(
... function,
... )(RequiresContextIOResult.no_args) == IOFailure('<0')
>>> assert RequiresContextIOResult.from_failure(':(').bind_result(
... function,
... )(RequiresContextIOResult.no_args) == IOFailure(':(')
function (Callable
[[TypeVar
(_ValueType
, covariant=True)], Result
[TypeVar
(_NewValueType
), TypeVar
(_ErrorType
)]]) –
RequiresContextIOResult
[TypeVar
(_NewValueType
), TypeVar
(_ErrorType
), TypeVar
(_EnvType
, contravariant=True)]
Binds RequiresContext
returning function to current container.
>>> from returns.context import RequiresContext
>>> from returns.io import IOSuccess, IOFailure
>>> def function(arg: int) -> RequiresContext[int, str]:
... return RequiresContext(lambda deps: len(deps) + arg)
>>> assert function(2)('abc') == 5
>>> assert RequiresContextIOResult.from_value(2).bind_context(
... function,
... )('abc') == IOSuccess(5)
>>> assert RequiresContextIOResult.from_failure(2).bind_context(
... function,
... )('abc') == IOFailure(2)
function (Callable
[[TypeVar
(_ValueType
, covariant=True)], RequiresContext
[TypeVar
(_NewValueType
), TypeVar
(_EnvType
, contravariant=True)]]) –
RequiresContextIOResult
[TypeVar
(_NewValueType
), TypeVar
(_ErrorType
), TypeVar
(_EnvType
, contravariant=True)]
Binds RequiresContextResult
returning function to the current one.
>>> from returns.context import RequiresContextResult
>>> from returns.io import IOSuccess, IOFailure
>>> from returns.result import Success, Failure
>>> def function(arg: int) -> RequiresContextResult[int, int, str]:
... if arg > 0:
... return RequiresContextResult(
... lambda deps: Success(len(deps) + arg),
... )
... return RequiresContextResult(
... lambda deps: Failure(len(deps) + arg),
... )
>>> assert function(2)('abc') == Success(5)
>>> assert function(-1)('abc') == Failure(2)
>>> assert RequiresContextIOResult.from_value(
... 2,
... ).bind_context_result(
... function,
... )('abc') == IOSuccess(5)
>>> assert RequiresContextIOResult.from_value(
... -1,
... ).bind_context_result(
... function,
... )('abc') == IOFailure(2)
>>> assert RequiresContextIOResult.from_failure(
... 2,
... ).bind_context_result(
... function,
... )('abc') == IOFailure(2)
function (Callable
[[TypeVar
(_ValueType
, covariant=True)], RequiresContextResult
[TypeVar
(_NewValueType
), TypeVar
(_ErrorType
), TypeVar
(_EnvType
, contravariant=True)]]) –
RequiresContextIOResult
[TypeVar
(_NewValueType
), TypeVar
(_ErrorType
), TypeVar
(_EnvType
, contravariant=True)]
Binds IO
returning function to the current container.
>>> from returns.context import RequiresContextIOResult
>>> from returns.io import IO, IOSuccess, IOFailure
>>> def function(number: int) -> IO[str]:
... return IO(str(number))
>>> assert RequiresContextIOResult.from_value(1).bind_io(
... function,
... )(RequiresContextIOResult.no_args) == IOSuccess('1')
>>> assert RequiresContextIOResult.from_failure(1).bind_io(
... function,
... )(RequiresContextIOResult.no_args) == IOFailure(1)
function (Callable
[[TypeVar
(_ValueType
, covariant=True)], IO
[TypeVar
(_NewValueType
)]]) –
RequiresContextIOResult
[TypeVar
(_NewValueType
), TypeVar
(_ErrorType
), TypeVar
(_EnvType
, contravariant=True)]
Binds IOResult
returning function to the current container.
>>> from returns.context import RequiresContextIOResult
>>> from returns.io import IOResult, IOSuccess, IOFailure
>>> def function(num: int) -> IOResult[int, str]:
... return IOSuccess(num + 1) if num > 0 else IOFailure('<0')
>>> assert RequiresContextIOResult.from_value(1).bind_ioresult(
... function,
... )(RequiresContextIOResult.no_args) == IOSuccess(2)
>>> assert RequiresContextIOResult.from_value(0).bind_ioresult(
... function,
... )(RequiresContextIOResult.no_args) == IOFailure('<0')
>>> assert RequiresContextIOResult.from_failure(':(').bind_ioresult(
... function,
... )(RequiresContextIOResult.no_args) == IOFailure(':(')
function (Callable
[[TypeVar
(_ValueType
, covariant=True)], IOResult
[TypeVar
(_NewValueType
), TypeVar
(_ErrorType
)]]) –
RequiresContextIOResult
[TypeVar
(_NewValueType
), TypeVar
(_ErrorType
), TypeVar
(_EnvType
, contravariant=True)]
Composes failed container with a pure function.
>>> from returns.context import RequiresContextIOResult
>>> from returns.io import IOSuccess, IOFailure
>>> assert RequiresContextIOResult.from_value(1).alt(
... lambda x: x + 1,
... )(...) == IOSuccess(1)
>>> assert RequiresContextIOResult.from_failure(1).alt(
... lambda x: x + 1,
... )(...) == IOFailure(2)
function (Callable
[[TypeVar
(_ErrorType
)], TypeVar
(_NewErrorType
)]) –
RequiresContextIOResult
[TypeVar
(_ValueType
, covariant=True), TypeVar
(_NewErrorType
), TypeVar
(_EnvType
, contravariant=True)]
Composes this container with a function returning the same type.
>>> from returns.context import RequiresContextIOResult
>>> from returns.io import IOSuccess, IOFailure
>>> def lashable(
... arg: str,
... ) -> RequiresContextIOResult[str, str, str]:
... if len(arg) > 1:
... return RequiresContextIOResult(
... lambda deps: IOSuccess(deps + arg),
... )
... return RequiresContextIOResult(
... lambda deps: IOFailure(arg + deps),
... )
>>> assert RequiresContextIOResult.from_value('a').lash(
... lashable,
... )('c') == IOSuccess('a')
>>> assert RequiresContextIOResult.from_failure('a').lash(
... lashable,
... )('c') == IOFailure('ac')
>>> assert RequiresContextIOResult.from_failure('aa').lash(
... lashable,
... )('b') == IOSuccess('baa')
function (Callable
[[TypeVar
(_ErrorType
)], KindN
[RequiresContextIOResult
, TypeVar
(_ValueType
, covariant=True), TypeVar
(_NewErrorType
), TypeVar
(_EnvType
, contravariant=True)]]) –
RequiresContextIOResult
[TypeVar
(_ValueType
, covariant=True), TypeVar
(_NewErrorType
), TypeVar
(_EnvType
, contravariant=True)]
Composes inner Result
with ReaderIOResult
returning function.
Can be useful when you need an access to both states of the result.
>>> from returns.context import ReaderIOResult, NoDeps
>>> from returns.io import IOSuccess, IOFailure
>>> from returns.result import Result
>>> def count(
... container: Result[int, int],
... ) -> ReaderIOResult[int, int, NoDeps]:
... return ReaderIOResult.from_result(
... container.map(lambda x: x + 1).alt(abs),
... )
>>> success = ReaderIOResult.from_value(1)
>>> failure = ReaderIOResult.from_failure(-1)
>>> assert success.compose_result(count)(...) == IOSuccess(2)
>>> assert failure.compose_result(count)(...) == IOFailure(1)
function (Callable
[[Result
[TypeVar
(_ValueType
, covariant=True), TypeVar
(_ErrorType
)]], KindN
[RequiresContextIOResult
, TypeVar
(_NewValueType
), TypeVar
(_ErrorType
), TypeVar
(_EnvType
, contravariant=True)]]) –
RequiresContextIOResult
[TypeVar
(_NewValueType
), TypeVar
(_ErrorType
), TypeVar
(_EnvType
, contravariant=True)]
Allows to modify the environment type.
>>> from returns.context import RequiresContextIOResultE
>>> from returns.io import IOSuccess, impure_safe
>>> def div(arg: int) -> RequiresContextIOResultE[float, int]:
... return RequiresContextIOResultE(
... impure_safe(lambda deps: arg / deps),
... )
>>> assert div(3).modify_env(int)('2') == IOSuccess(1.5)
>>> assert div(3).modify_env(int)('0').failure()
function (Callable
[[TypeVar
(_NewEnvType
)], TypeVar
(_EnvType
, contravariant=True)]) –
RequiresContextIOResult
[TypeVar
(_ValueType
, covariant=True), TypeVar
(_ErrorType
), TypeVar
(_NewEnvType
)]
Is used to get the current dependencies inside the call stack.
Similar to returns.context.requires_context.RequiresContext.ask()
,
but returns IOResult
instead of a regular value.
Please, refer to the docs there to learn how to use it.
One important note that is worth duplicating here:
you might need to provide _EnvType
explicitly,
so mypy
will know about it statically.
>>> from returns.context import RequiresContextIOResultE
>>> from returns.io import IOSuccess
>>> assert RequiresContextIOResultE[int, int].ask().map(
... str,
... )(1) == IOSuccess('1')
RequiresContextIOResult
[TypeVar
(_EnvType
, contravariant=True), TypeVar
(_ErrorType
), TypeVar
(_EnvType
, contravariant=True)]
Creates new container with Result
as a unit value.
>>> from returns.context import RequiresContextIOResult
>>> from returns.result import Success, Failure
>>> from returns.io import IOSuccess, IOFailure
>>> deps = RequiresContextIOResult.no_args
>>> assert RequiresContextIOResult.from_result(
... Success(1),
... )(deps) == IOSuccess(1)
>>> assert RequiresContextIOResult.from_result(
... Failure(1),
... )(deps) == IOFailure(1)
inner_value (Result
[TypeVar
(_NewValueType
), TypeVar
(_NewErrorType
)]) –
RequiresContextIOResult
[TypeVar
(_NewValueType
), TypeVar
(_NewErrorType
), Any
]
Creates new container from successful IO
value.
>>> from returns.io import IO, IOSuccess
>>> from returns.context import RequiresContextIOResult
>>> assert RequiresContextIOResult.from_io(IO(1))(
... RequiresContextIOResult.no_args,
... ) == IOSuccess(1)
inner_value (IO
[TypeVar
(_NewValueType
)]) –
RequiresContextIOResult
[TypeVar
(_NewValueType
), Any
, Any
]
Creates a new container from failed IO
value.
>>> from returns.io import IO, IOFailure
>>> from returns.context import RequiresContextIOResult
>>> assert RequiresContextIOResult.from_failed_io(IO(1))(
... RequiresContextIOResult.no_args,
... ) == IOFailure(1)
inner_value (IO
[TypeVar
(_NewErrorType
)]) –
RequiresContextIOResult
[Any
, TypeVar
(_NewErrorType
), Any
]
Creates new container with IOResult
as a unit value.
>>> from returns.context import RequiresContextIOResult
>>> from returns.io import IOSuccess, IOFailure
>>> deps = RequiresContextIOResult.no_args
>>> assert RequiresContextIOResult.from_ioresult(
... IOSuccess(1),
... )(deps) == IOSuccess(1)
>>> assert RequiresContextIOResult.from_ioresult(
... IOFailure(1),
... )(deps) == IOFailure(1)
inner_value (IOResult
[TypeVar
(_NewValueType
), TypeVar
(_NewErrorType
)]) –
RequiresContextIOResult
[TypeVar
(_NewValueType
), TypeVar
(_NewErrorType
), Any
]
Creates new container with ReaderIOResult
as a unit value.
>>> from returns.context import RequiresContextIOResult
>>> from returns.io import IOSuccess, IOFailure
>>> assert RequiresContextIOResult.from_ioresult_context(
... RequiresContextIOResult.from_value(1),
... )(...) == IOSuccess(1)
>>> assert RequiresContextIOResult.from_ioresult_context(
... RequiresContextIOResult.from_failure(1),
... )(...) == IOFailure(1)
inner_value (RequiresContextIOResult
[TypeVar
(_NewValueType
), TypeVar
(_NewErrorType
), TypeVar
(_NewEnvType
)]) –
RequiresContextIOResult
[TypeVar
(_NewValueType
), TypeVar
(_NewErrorType
), TypeVar
(_NewEnvType
)]
You might end up with RequiresContext[IOResult]
as a value.
This method is designed to turn it into RequiresContextIOResult
.
It will save all the typing information.
It is just more useful!
>>> from returns.context import RequiresContext
>>> from returns.io import IOSuccess, IOFailure
>>> assert RequiresContextIOResult.from_typecast(
... RequiresContext.from_value(IOSuccess(1)),
... )(RequiresContextIOResult.no_args) == IOSuccess(1)
>>> assert RequiresContextIOResult.from_typecast(
... RequiresContext.from_value(IOFailure(1)),
... )(RequiresContextIOResult.no_args) == IOFailure(1)
inner_value (RequiresContext
[IOResult
[TypeVar
(_NewValueType
), TypeVar
(_NewErrorType
)], TypeVar
(_EnvType
, contravariant=True)]) –
RequiresContextIOResult
[TypeVar
(_NewValueType
), TypeVar
(_NewErrorType
), TypeVar
(_EnvType
, contravariant=True)]
Creates new container from RequiresContext
as a success unit.
>>> from returns.context import RequiresContext
>>> from returns.io import IOSuccess
>>> assert RequiresContextIOResult.from_context(
... RequiresContext.from_value(1),
... )(...) == IOSuccess(1)
inner_value (RequiresContext
[TypeVar
(_NewValueType
), TypeVar
(_NewEnvType
)]) –
RequiresContextIOResult
[TypeVar
(_NewValueType
), Any
, TypeVar
(_NewEnvType
)]
Creates new container from RequiresContext
as a failure unit.
>>> from returns.context import RequiresContext
>>> from returns.io import IOFailure
>>> assert RequiresContextIOResult.from_failed_context(
... RequiresContext.from_value(1),
... )(...) == IOFailure(1)
inner_value (RequiresContext
[TypeVar
(_NewValueType
), TypeVar
(_NewEnvType
)]) –
RequiresContextIOResult
[Any
, TypeVar
(_NewValueType
), TypeVar
(_NewEnvType
)]
Creates new container from RequiresContextResult
as a unit value.
>>> from returns.context import RequiresContextResult
>>> from returns.io import IOSuccess, IOFailure
>>> assert RequiresContextIOResult.from_result_context(
... RequiresContextResult.from_value(1),
... )(...) == IOSuccess(1)
>>> assert RequiresContextIOResult.from_result_context(
... RequiresContextResult.from_failure(1),
... )(...) == IOFailure(1)
inner_value (RequiresContextResult
[TypeVar
(_NewValueType
), TypeVar
(_NewErrorType
), TypeVar
(_NewEnvType
)]) –
RequiresContextIOResult
[TypeVar
(_NewValueType
), TypeVar
(_NewErrorType
), TypeVar
(_NewEnvType
)]
Creates new container with IOSuccess(inner_value)
as a unit value.
>>> from returns.context import RequiresContextIOResult
>>> from returns.io import IOSuccess
>>> assert RequiresContextIOResult.from_value(1)(
... RequiresContextIOResult.no_args,
... ) == IOSuccess(1)
inner_value (TypeVar
(_NewValueType
)) –
RequiresContextIOResult
[TypeVar
(_NewValueType
), Any
, Any
]
Creates new container with IOFailure(inner_value)
as a unit value.
>>> from returns.context import RequiresContextIOResult
>>> from returns.io import IOFailure
>>> assert RequiresContextIOResult.from_failure(1)(
... RequiresContextIOResult.no_args,
... ) == IOFailure(1)
inner_value (TypeVar
(_NewErrorType
)) –
RequiresContextIOResult
[Any
, TypeVar
(_NewErrorType
), Any
]
Alias for a popular case when Result
has Exception
as error type.
alias of RequiresContextIOResult
[_ValueType
, Exception
, _EnvType
]
Alias to save you some typing. Uses original name from Haskell.
inner_value (Callable
[[TypeVar
(_EnvType
, contravariant=True)], IOResult
[TypeVar
(_ValueType
, covariant=True), TypeVar
(_ErrorType
)]]) –
Alias to save you some typing. Uses Exception
as error type.
alias of RequiresContextIOResult
[_ValueType
, Exception
, _EnvType
]
Bases: BaseContainer
, SupportsKindN
[RequiresContextFutureResult
, _ValueType
, _ErrorType
, _EnvType
], ReaderFutureResultBasedN
[_ValueType
, _ErrorType
, _EnvType
], FutureResultLikeN
[_ValueType
, _ErrorType
, _EnvType
]
The RequiresContextFutureResult
combinator.
This probably the main type people are going to use in async
programs.
See returns.context.requires_context.RequiresContext
,
returns.context.requires_context_result.RequiresContextResult
,
and
returns.context.requires_context_result.RequiresContextIOResult
for more docs.
This is just a handy wrapper around
RequiresContext[FutureResult[a, b], env]
which represents a context-dependent impure async operation that might fail.
So, this is a thin wrapper, without any changes in logic. Why do we need this wrapper? That’s just for better usability!
This way RequiresContextIOResult
allows to simply work with:
raw values and pure functions
RequiresContext
values and pure functions returning it
RequiresContextResult
values and pure functions returning it
RequiresContextIOResult
values and pure functions returning it
Result
and pure functions returning it
IOResult
and functions returning it
FutureResult
and functions returning it
other RequiresContextFutureResult
related functions and values
This is a complex type for complex tasks!
Important implementation details
Due it is meaning, RequiresContextFutureResult
cannot have Success
and Failure
subclasses.
We only have just one type. That’s by design.
Different converters are also not supported for this type.
Use converters inside the RequiresContext
context, not outside.
See also
inner_value (Callable
[[TypeVar
(_EnvType
, contravariant=True)], FutureResult
[TypeVar
(_ValueType
, covariant=True), TypeVar
(_ErrorType
, covariant=True)]]) –
A convenient placeholder to call methods created by .from_value().
Swaps value and error types.
So, values become errors and errors become values.
It is useful when you have to work with errors a lot.
And since we have a lot of .bind_
related methods
and only a single .lash
- it is easier to work with values.
>>> import anyio
>>> from returns.context import RequiresContextFutureResult
>>> from returns.io import IOSuccess, IOFailure
>>> success = RequiresContextFutureResult.from_value(1)
>>> failure = RequiresContextFutureResult.from_failure(1)
>>> assert anyio.run(success.swap(), ...) == IOFailure(1)
>>> assert anyio.run(failure.swap(), ...) == IOSuccess(1)
RequiresContextFutureResult
[TypeVar
(_ErrorType
, covariant=True), TypeVar
(_ValueType
, covariant=True), TypeVar
(_EnvType
, contravariant=True)]
Composes successful container with a pure function.
>>> import anyio
>>> from returns.context import RequiresContextFutureResult
>>> from returns.io import IOSuccess, IOFailure
>>> assert anyio.run(RequiresContextFutureResult.from_value(1).map(
... lambda x: x + 1,
... )(...).awaitable) == IOSuccess(2)
>>> assert anyio.run(RequiresContextFutureResult.from_failure(1).map(
... lambda x: x + 1,
... )(...).awaitable) == IOFailure(1)
function (Callable
[[TypeVar
(_ValueType
, covariant=True)], TypeVar
(_NewValueType
)]) –
RequiresContextFutureResult
[TypeVar
(_NewValueType
), TypeVar
(_ErrorType
, covariant=True), TypeVar
(_EnvType
, contravariant=True)]
Calls a wrapped function in a container on this container.
>>> import anyio
>>> from returns.context import RequiresContextFutureResult
>>> from returns.io import IOSuccess, IOFailure
>>> def transform(arg: str) -> str:
... return arg + 'b'
>>> assert anyio.run(
... RequiresContextFutureResult.from_value('a').apply(
... RequiresContextFutureResult.from_value(transform),
... ),
... RequiresContextFutureResult.no_args,
... ) == IOSuccess('ab')
>>> assert anyio.run(
... RequiresContextFutureResult.from_failure('a').apply(
... RequiresContextFutureResult.from_value(transform),
... ),
... RequiresContextFutureResult.no_args,
... ) == IOFailure('a')
container (KindN
[RequiresContextFutureResult
, Callable
[[TypeVar
(_ValueType
, covariant=True)], TypeVar
(_NewValueType
)], TypeVar
(_ErrorType
, covariant=True), TypeVar
(_EnvType
, contravariant=True)]) –
RequiresContextFutureResult
[TypeVar
(_NewValueType
), TypeVar
(_ErrorType
, covariant=True), TypeVar
(_EnvType
, contravariant=True)]
Composes this container with a function returning the same type.
>>> import anyio
>>> from returns.context import RequiresContextFutureResult
>>> from returns.future import FutureResult
>>> from returns.io import IOSuccess, IOFailure
>>> def function(
... number: int,
... ) -> RequiresContextFutureResult[str, int, int]:
... # `deps` has `int` type here:
... return RequiresContextFutureResult(
... lambda deps: FutureResult.from_value(str(number + deps)),
... )
>>> assert anyio.run(
... RequiresContextFutureResult.from_value(2).bind(function),
... 3,
... ) == IOSuccess('5')
>>> assert anyio.run(
... RequiresContextFutureResult.from_failure(2).bind(function),
... 3,
... ) == IOFailure(2)
function (Callable
[[TypeVar
(_ValueType
, covariant=True)], KindN
[RequiresContextFutureResult
, TypeVar
(_NewValueType
), TypeVar
(_ErrorType
, covariant=True), TypeVar
(_EnvType
, contravariant=True)]]) –
RequiresContextFutureResult
[TypeVar
(_NewValueType
), TypeVar
(_ErrorType
, covariant=True), TypeVar
(_EnvType
, contravariant=True)]
Alias for bind_context_future_result method, it is the same as bind here.
function (Callable
[[TypeVar
(_ValueType
, covariant=True)], KindN
[RequiresContextFutureResult
, TypeVar
(_NewValueType
), TypeVar
(_ErrorType
, covariant=True), TypeVar
(_EnvType
, contravariant=True)]]) –
RequiresContextFutureResult
[TypeVar
(_NewValueType
), TypeVar
(_ErrorType
, covariant=True), TypeVar
(_EnvType
, contravariant=True)]
Composes this container with a async function returning the same type.
>>> import anyio
>>> from returns.context import RequiresContextFutureResult
>>> from returns.io import IOSuccess, IOFailure
>>> async def function(
... number: int,
... ) -> RequiresContextFutureResult[str, int, int]:
... return RequiresContextFutureResult.from_value(number + 1)
>>> assert anyio.run(
... RequiresContextFutureResult.from_value(1).bind_async(
... function,
... ),
... RequiresContextFutureResult.no_args,
... ) == IOSuccess(2)
>>> assert anyio.run(
... RequiresContextFutureResult.from_failure(1).bind_async(
... function,
... ),
... RequiresContextFutureResult.no_args,
... ) == IOFailure(1)
function (Callable
[[TypeVar
(_ValueType
, covariant=True)], Awaitable
[KindN
[RequiresContextFutureResult
, TypeVar
(_NewValueType
), TypeVar
(_ErrorType
, covariant=True), TypeVar
(_EnvType
, contravariant=True)]]]) –
RequiresContextFutureResult
[TypeVar
(_NewValueType
), TypeVar
(_ErrorType
, covariant=True), TypeVar
(_EnvType
, contravariant=True)]
Alias for bind_async_context_future_result method, it is the same as bind_async here.
function (Callable
[[TypeVar
(_ValueType
, covariant=True)], Awaitable
[KindN
[RequiresContextFutureResult
, TypeVar
(_NewValueType
), TypeVar
(_ErrorType
, covariant=True), TypeVar
(_EnvType
, contravariant=True)]]]) –
RequiresContextFutureResult
[TypeVar
(_NewValueType
), TypeVar
(_ErrorType
, covariant=True), TypeVar
(_EnvType
, contravariant=True)]
Allows to compose a container and a regular async
function.
This function should return plain, non-container value.
See bind_async()
to bind async
function that returns a container.
>>> import anyio
>>> from returns.context import RequiresContextFutureResult
>>> from returns.io import IOSuccess, IOFailure
>>> async def coroutine(x: int) -> int:
... return x + 1
>>> assert anyio.run(
... RequiresContextFutureResult.from_value(1).bind_awaitable(
... coroutine,
... ),
... RequiresContextFutureResult.no_args,
... ) == IOSuccess(2)
>>> assert anyio.run(
... RequiresContextFutureResult.from_failure(1).bind_awaitable(
... coroutine,
... ),
... RequiresContextFutureResult.no_args,
... ) == IOFailure(1)
function (Callable
[[TypeVar
(_ValueType
, covariant=True)], Awaitable
[TypeVar
(_NewValueType
)]]) –
RequiresContextFutureResult
[TypeVar
(_NewValueType
), TypeVar
(_ErrorType
, covariant=True), TypeVar
(_EnvType
, contravariant=True)]
Binds Result
returning function to the current container.
>>> import anyio
>>> from returns.context import RequiresContextFutureResult
>>> from returns.result import Success, Result
>>> from returns.io import IOSuccess, IOFailure
>>> def function(num: int) -> Result[int, str]:
... return Success(num + 1)
>>> assert anyio.run(
... RequiresContextFutureResult.from_value(1).bind_result(
... function,
... ),
... RequiresContextFutureResult.no_args,
... ) == IOSuccess(2)
>>> assert anyio.run(
... RequiresContextFutureResult.from_failure(':(').bind_result(
... function,
... ),
... RequiresContextFutureResult.no_args,
... ) == IOFailure(':(')
function (Callable
[[TypeVar
(_ValueType
, covariant=True)], Result
[TypeVar
(_NewValueType
), TypeVar
(_ErrorType
, covariant=True)]]) –
RequiresContextFutureResult
[TypeVar
(_NewValueType
), TypeVar
(_ErrorType
, covariant=True), TypeVar
(_EnvType
, contravariant=True)]
Binds RequiresContext
returning function to current container.
>>> import anyio
>>> from returns.context import RequiresContext
>>> from returns.io import IOSuccess, IOFailure
>>> def function(arg: int) -> RequiresContext[int, str]:
... return RequiresContext(lambda deps: len(deps) + arg)
>>> assert anyio.run(
... RequiresContextFutureResult.from_value(2).bind_context(
... function,
... ),
... 'abc',
... ) == IOSuccess(5)
>>> assert anyio.run(
... RequiresContextFutureResult.from_failure(0).bind_context(
... function,
... ),
... 'abc',
... ) == IOFailure(0)
function (Callable
[[TypeVar
(_ValueType
, covariant=True)], RequiresContext
[TypeVar
(_NewValueType
), TypeVar
(_EnvType
, contravariant=True)]]) –
RequiresContextFutureResult
[TypeVar
(_NewValueType
), TypeVar
(_ErrorType
, covariant=True), TypeVar
(_EnvType
, contravariant=True)]
Binds RequiresContextResult
returning function to the current one.
>>> import anyio
>>> from returns.context import RequiresContextResult
>>> from returns.io import IOSuccess, IOFailure
>>> from returns.result import Success
>>> def function(arg: int) -> RequiresContextResult[int, int, str]:
... return RequiresContextResult(
... lambda deps: Success(len(deps) + arg),
... )
>>> instance = RequiresContextFutureResult.from_value(
... 2,
... ).bind_context_result(
... function,
... )('abc')
>>> assert anyio.run(instance.awaitable) == IOSuccess(5)
>>> instance = RequiresContextFutureResult.from_failure(
... 2,
... ).bind_context_result(
... function,
... )('abc')
>>> assert anyio.run(instance.awaitable) == IOFailure(2)
function (Callable
[[TypeVar
(_ValueType
, covariant=True)], RequiresContextResult
[TypeVar
(_NewValueType
), TypeVar
(_ErrorType
, covariant=True), TypeVar
(_EnvType
, contravariant=True)]]) –
RequiresContextFutureResult
[TypeVar
(_NewValueType
), TypeVar
(_ErrorType
, covariant=True), TypeVar
(_EnvType
, contravariant=True)]
Binds RequiresContextIOResult
returning function to the current one.
>>> import anyio
>>> from returns.context import RequiresContextIOResult
>>> from returns.io import IOSuccess, IOFailure
>>> def function(arg: int) -> RequiresContextIOResult[int, int, str]:
... return RequiresContextIOResult(
... lambda deps: IOSuccess(len(deps) + arg),
... )
>>> instance = RequiresContextFutureResult.from_value(
... 2,
... ).bind_context_ioresult(
... function,
... )('abc')
>>> assert anyio.run(instance.awaitable) == IOSuccess(5)
>>> instance = RequiresContextFutureResult.from_failure(
... 2,
... ).bind_context_ioresult(
... function,
... )('abc')
>>> assert anyio.run(instance.awaitable) == IOFailure(2)
function (Callable
[[TypeVar
(_ValueType
, covariant=True)], RequiresContextIOResult
[TypeVar
(_NewValueType
), TypeVar
(_ErrorType
, covariant=True), TypeVar
(_EnvType
, contravariant=True)]]) –
RequiresContextFutureResult
[TypeVar
(_NewValueType
), TypeVar
(_ErrorType
, covariant=True), TypeVar
(_EnvType
, contravariant=True)]
Binds IO
returning function to the current container.
>>> import anyio
>>> from returns.context import RequiresContextFutureResult
>>> from returns.io import IO, IOSuccess, IOFailure
>>> def do_io(number: int) -> IO[str]:
... return IO(str(number)) # not IO operation actually
>>> assert anyio.run(
... RequiresContextFutureResult.from_value(1).bind_io(do_io),
... RequiresContextFutureResult.no_args,
... ) == IOSuccess('1')
>>> assert anyio.run(
... RequiresContextFutureResult.from_failure(1).bind_io(do_io),
... RequiresContextFutureResult.no_args,
... ) == IOFailure(1)
function (Callable
[[TypeVar
(_ValueType
, covariant=True)], IO
[TypeVar
(_NewValueType
)]]) –
RequiresContextFutureResult
[TypeVar
(_NewValueType
), TypeVar
(_ErrorType
, covariant=True), TypeVar
(_EnvType
, contravariant=True)]
Binds IOResult
returning function to the current container.
>>> import anyio
>>> from returns.context import RequiresContextFutureResult
>>> from returns.io import IOResult, IOSuccess, IOFailure
>>> def function(num: int) -> IOResult[int, str]:
... return IOSuccess(num + 1)
>>> assert anyio.run(
... RequiresContextFutureResult.from_value(1).bind_ioresult(
... function,
... ),
... RequiresContextFutureResult.no_args,
... ) == IOSuccess(2)
>>> assert anyio.run(
... RequiresContextFutureResult.from_failure(':(').bind_ioresult(
... function,
... ),
... RequiresContextFutureResult.no_args,
... ) == IOFailure(':(')
function (Callable
[[TypeVar
(_ValueType
, covariant=True)], IOResult
[TypeVar
(_NewValueType
), TypeVar
(_ErrorType
, covariant=True)]]) –
RequiresContextFutureResult
[TypeVar
(_NewValueType
), TypeVar
(_ErrorType
, covariant=True), TypeVar
(_EnvType
, contravariant=True)]
Binds Future
returning function to the current container.
>>> import anyio
>>> from returns.context import RequiresContextFutureResult
>>> from returns.future import Future
>>> from returns.io import IOSuccess, IOFailure
>>> def function(num: int) -> Future[int]:
... return Future.from_value(num + 1)
>>> assert anyio.run(
... RequiresContextFutureResult.from_value(1).bind_future(
... function,
... ),
... RequiresContextFutureResult.no_args,
... ) == IOSuccess(2)
>>> failed = RequiresContextFutureResult.from_failure(':(')
>>> assert anyio.run(
... failed.bind_future(function),
... RequiresContextFutureResult.no_args,
... ) == IOFailure(':(')
function (Callable
[[TypeVar
(_ValueType
, covariant=True)], Future
[TypeVar
(_NewValueType
)]]) –
RequiresContextFutureResult
[TypeVar
(_NewValueType
), TypeVar
(_ErrorType
, covariant=True), TypeVar
(_EnvType
, contravariant=True)]
Binds FutureResult
returning function to the current container.
>>> import anyio
>>> from returns.context import RequiresContextFutureResult
>>> from returns.future import FutureResult
>>> from returns.io import IOSuccess, IOFailure
>>> def function(num: int) -> FutureResult[int, str]:
... return FutureResult.from_value(num + 1)
>>> assert anyio.run(
... RequiresContextFutureResult.from_value(1).bind_future_result(
... function,
... ),
... RequiresContextFutureResult.no_args,
... ) == IOSuccess(2)
>>> failed = RequiresContextFutureResult.from_failure(':(')
>>> assert anyio.run(
... failed.bind_future_result(function),
... RequiresContextFutureResult.no_args,
... ) == IOFailure(':(')
function (Callable
[[TypeVar
(_ValueType
, covariant=True)], FutureResult
[TypeVar
(_NewValueType
), TypeVar
(_ErrorType
, covariant=True)]]) –
RequiresContextFutureResult
[TypeVar
(_NewValueType
), TypeVar
(_ErrorType
, covariant=True), TypeVar
(_EnvType
, contravariant=True)]
Binds Future
returning async function to the current container.
>>> import anyio
>>> from returns.context import RequiresContextFutureResult
>>> from returns.future import Future
>>> from returns.io import IOSuccess, IOFailure
>>> async def function(num: int) -> Future[int]:
... return Future.from_value(num + 1)
>>> assert anyio.run(
... RequiresContextFutureResult.from_value(1).bind_async_future(
... function,
... ),
... RequiresContextFutureResult.no_args,
... ) == IOSuccess(2)
>>> failed = RequiresContextFutureResult.from_failure(':(')
>>> assert anyio.run(
... failed.bind_async_future(function),
... RequiresContextFutureResult.no_args,
... ) == IOFailure(':(')
function (Callable
[[TypeVar
(_ValueType
, covariant=True)], Awaitable
[Future
[TypeVar
(_NewValueType
)]]]) –
RequiresContextFutureResult
[TypeVar
(_NewValueType
), TypeVar
(_ErrorType
, covariant=True), TypeVar
(_EnvType
, contravariant=True)]
Bind FutureResult
returning async function to the current container.
>>> import anyio
>>> from returns.context import RequiresContextFutureResult
>>> from returns.future import FutureResult
>>> from returns.io import IOSuccess, IOFailure
>>> async def function(num: int) -> FutureResult[int, str]:
... return FutureResult.from_value(num + 1)
>>> assert anyio.run(
... RequiresContextFutureResult.from_value(
... 1,
... ).bind_async_future_result(
... function,
... ),
... RequiresContextFutureResult.no_args,
... ) == IOSuccess(2)
>>> failed = RequiresContextFutureResult.from_failure(':(')
>>> assert anyio.run(
... failed.bind_async_future_result(function),
... RequiresContextFutureResult.no_args,
... ) == IOFailure(':(')
function (Callable
[[TypeVar
(_ValueType
, covariant=True)], Awaitable
[FutureResult
[TypeVar
(_NewValueType
), TypeVar
(_ErrorType
, covariant=True)]]]) –
RequiresContextFutureResult
[TypeVar
(_NewValueType
), TypeVar
(_ErrorType
, covariant=True), TypeVar
(_EnvType
, contravariant=True)]
Composes failed container with a pure function.
>>> import anyio
>>> from returns.context import RequiresContextFutureResult
>>> from returns.io import IOSuccess, IOFailure
>>> assert anyio.run(
... RequiresContextFutureResult.from_value(1).alt(
... lambda x: x + 1,
... ),
... RequiresContextFutureResult.no_args,
... ) == IOSuccess(1)
>>> assert anyio.run(
... RequiresContextFutureResult.from_failure(1).alt(
... lambda x: x + 1,
... ),
... RequiresContextFutureResult.no_args,
... ) == IOFailure(2)
function (Callable
[[TypeVar
(_ErrorType
, covariant=True)], TypeVar
(_NewErrorType
)]) –
RequiresContextFutureResult
[TypeVar
(_ValueType
, covariant=True), TypeVar
(_NewErrorType
), TypeVar
(_EnvType
, contravariant=True)]
Composes this container with a function returning the same type.
>>> import anyio
>>> from returns.context import RequiresContextFutureResult
>>> from returns.future import FutureResult
>>> from returns.io import IOSuccess
>>> def lashable(
... arg: str,
... ) -> RequiresContextFutureResult[str, str, str]:
... return RequiresContextFutureResult(
... lambda deps: FutureResult.from_value(
... deps + arg,
... ),
... )
>>> assert anyio.run(
... RequiresContextFutureResult.from_value('a').lash(lashable),
... 'c',
... ) == IOSuccess('a')
>>> assert anyio.run(
... RequiresContextFutureResult.from_failure('aa').lash(
... lashable,
... ),
... 'b',
... ) == IOSuccess('baa')
function (Callable
[[TypeVar
(_ErrorType
, covariant=True)], KindN
[RequiresContextFutureResult
, TypeVar
(_ValueType
, covariant=True), TypeVar
(_NewErrorType
), TypeVar
(_EnvType
, contravariant=True)]]) –
RequiresContextFutureResult
[TypeVar
(_ValueType
, covariant=True), TypeVar
(_NewErrorType
), TypeVar
(_EnvType
, contravariant=True)]
Composes inner Result
with ReaderFutureResult
returning func.
Can be useful when you need an access to both states of the result.
>>> import anyio
>>> from returns.context import ReaderFutureResult, NoDeps
>>> from returns.io import IOSuccess, IOFailure
>>> from returns.result import Result
>>> def count(
... container: Result[int, int],
... ) -> ReaderFutureResult[int, int, NoDeps]:
... return ReaderFutureResult.from_result(
... container.map(lambda x: x + 1).alt(abs),
... )
>>> success = ReaderFutureResult.from_value(1)
>>> failure = ReaderFutureResult.from_failure(-1)
>>> assert anyio.run(
... success.compose_result(count), ReaderFutureResult.no_args,
... ) == IOSuccess(2)
>>> assert anyio.run(
... failure.compose_result(count), ReaderFutureResult.no_args,
... ) == IOFailure(1)
function (Callable
[[Result
[TypeVar
(_ValueType
, covariant=True), TypeVar
(_ErrorType
, covariant=True)]], KindN
[RequiresContextFutureResult
, TypeVar
(_NewValueType
), TypeVar
(_ErrorType
, covariant=True), TypeVar
(_EnvType
, contravariant=True)]]) –
RequiresContextFutureResult
[TypeVar
(_NewValueType
), TypeVar
(_ErrorType
, covariant=True), TypeVar
(_EnvType
, contravariant=True)]
Allows to modify the environment type.
>>> import anyio
>>> from returns.future import future_safe, asyncify
>>> from returns.context import RequiresContextFutureResultE
>>> from returns.io import IOSuccess
>>> def div(arg: int) -> RequiresContextFutureResultE[float, int]:
... return RequiresContextFutureResultE(
... future_safe(asyncify(lambda deps: arg / deps)),
... )
>>> assert anyio.run(div(3).modify_env(int), '2') == IOSuccess(1.5)
>>> assert anyio.run(div(3).modify_env(int), '0').failure()
function (Callable
[[TypeVar
(_NewEnvType
)], TypeVar
(_EnvType
, contravariant=True)]) –
RequiresContextFutureResult
[TypeVar
(_ValueType
, covariant=True), TypeVar
(_ErrorType
, covariant=True), TypeVar
(_NewEnvType
)]
Is used to get the current dependencies inside the call stack.
Similar to
returns.context.requires_context.RequiresContext.ask()
,
but returns FutureResult
instead of a regular value.
Please, refer to the docs there to learn how to use it.
One important note that is worth duplicating here:
you might need to provide type annotations explicitly,
so mypy
will know about it statically.
>>> import anyio
>>> from returns.context import RequiresContextFutureResultE
>>> from returns.io import IOSuccess
>>> assert anyio.run(
... RequiresContextFutureResultE[int, int].ask().map(str),
... 1,
... ) == IOSuccess('1')
RequiresContextFutureResult
[TypeVar
(_EnvType
, contravariant=True), TypeVar
(_ErrorType
, covariant=True), TypeVar
(_EnvType
, contravariant=True)]
Creates new container with Result
as a unit value.
>>> import anyio
>>> from returns.context import RequiresContextFutureResult
>>> from returns.result import Success, Failure
>>> from returns.io import IOSuccess, IOFailure
>>> assert anyio.run(
... RequiresContextFutureResult.from_result(Success(1)),
... RequiresContextFutureResult.no_args,
... ) == IOSuccess(1)
>>> assert anyio.run(
... RequiresContextFutureResult.from_result(Failure(1)),
... RequiresContextFutureResult.no_args,
... ) == IOFailure(1)
inner_value (Result
[TypeVar
(_NewValueType
), TypeVar
(_NewErrorType
)]) –
RequiresContextFutureResult
[TypeVar
(_NewValueType
), TypeVar
(_NewErrorType
), Any
]
Creates new container from successful IO
value.
>>> import anyio
>>> from returns.io import IO, IOSuccess
>>> from returns.context import RequiresContextFutureResult
>>> assert anyio.run(
... RequiresContextFutureResult.from_io(IO(1)),
... RequiresContextFutureResult.no_args,
... ) == IOSuccess(1)
inner_value (IO
[TypeVar
(_NewValueType
)]) –
RequiresContextFutureResult
[TypeVar
(_NewValueType
), Any
, Any
]
Creates a new container from failed IO
value.
>>> import anyio
>>> from returns.io import IO, IOFailure
>>> from returns.context import RequiresContextFutureResult
>>> assert anyio.run(
... RequiresContextFutureResult.from_failed_io(IO(1)),
... RequiresContextFutureResult.no_args,
... ) == IOFailure(1)
inner_value (IO
[TypeVar
(_NewErrorType
)]) –
RequiresContextFutureResult
[Any
, TypeVar
(_NewErrorType
), Any
]
Creates new container with IOResult
as a unit value.
>>> import anyio
>>> from returns.context import RequiresContextFutureResult
>>> from returns.io import IOSuccess, IOFailure
>>> assert anyio.run(
... RequiresContextFutureResult.from_ioresult(IOSuccess(1)),
... RequiresContextFutureResult.no_args,
... ) == IOSuccess(1)
>>> assert anyio.run(
... RequiresContextFutureResult.from_ioresult(IOFailure(1)),
... RequiresContextFutureResult.no_args,
... ) == IOFailure(1)
inner_value (IOResult
[TypeVar
(_NewValueType
), TypeVar
(_NewErrorType
)]) –
RequiresContextFutureResult
[TypeVar
(_NewValueType
), TypeVar
(_NewErrorType
), Any
]
Creates new container with successful Future
as a unit value.
>>> import anyio
>>> from returns.context import RequiresContextFutureResult
>>> from returns.future import Future
>>> from returns.io import IOSuccess
>>> assert anyio.run(
... RequiresContextFutureResult.from_future(Future.from_value(1)),
... RequiresContextFutureResult.no_args,
... ) == IOSuccess(1)
inner_value (Future
[TypeVar
(_NewValueType
)]) –
RequiresContextFutureResult
[TypeVar
(_NewValueType
), Any
, Any
]
Creates new container with failed Future
as a unit value.
>>> import anyio
>>> from returns.context import RequiresContextFutureResult
>>> from returns.future import Future
>>> from returns.io import IOFailure
>>> assert anyio.run(
... RequiresContextFutureResult.from_failed_future(
... Future.from_value(1),
... ),
... RequiresContextFutureResult.no_args,
... ) == IOFailure(1)
inner_value (Future
[TypeVar
(_NewErrorType
)]) –
RequiresContextFutureResult
[Any
, TypeVar
(_NewErrorType
), Any
]
Creates new container with ReaderFutureResult
as a unit value.
>>> import anyio
>>> from returns.context import RequiresContextFutureResult
>>> from returns.io import IOSuccess, IOFailure
>>> assert anyio.run(
... RequiresContextFutureResult.from_future_result_context(
... RequiresContextFutureResult.from_value(1),
... ),
... RequiresContextFutureResult.no_args,
... ) == IOSuccess(1)
>>> assert anyio.run(
... RequiresContextFutureResult.from_future_result_context(
... RequiresContextFutureResult.from_failure(1),
... ),
... RequiresContextFutureResult.no_args,
... ) == IOFailure(1)
inner_value (RequiresContextFutureResult
[TypeVar
(_NewValueType
), TypeVar
(_NewErrorType
), TypeVar
(_NewEnvType
)]) –
RequiresContextFutureResult
[TypeVar
(_NewValueType
), TypeVar
(_NewErrorType
), TypeVar
(_NewEnvType
)]
Creates new container with FutureResult
as a unit value.
>>> import anyio
>>> from returns.context import RequiresContextFutureResult
>>> from returns.future import FutureResult
>>> from returns.io import IOSuccess, IOFailure
>>> assert anyio.run(
... RequiresContextFutureResult.from_future_result(
... FutureResult.from_value(1),
... ),
... RequiresContextFutureResult.no_args,
... ) == IOSuccess(1)
>>> assert anyio.run(
... RequiresContextFutureResult.from_future_result(
... FutureResult.from_failure(1),
... ),
... RequiresContextFutureResult.no_args,
... ) == IOFailure(1)
inner_value (FutureResult
[TypeVar
(_NewValueType
), TypeVar
(_NewErrorType
)]) –
RequiresContextFutureResult
[TypeVar
(_NewValueType
), TypeVar
(_NewErrorType
), Any
]
You might end up with RequiresContext[FutureResult]
as a value.
This method is designed to turn it into RequiresContextFutureResult
.
It will save all the typing information.
It is just more useful!
>>> import anyio
>>> from returns.context import RequiresContext
>>> from returns.future import FutureResult
>>> from returns.io import IOSuccess, IOFailure
>>> assert anyio.run(
... RequiresContextFutureResult.from_typecast(
... RequiresContext.from_value(FutureResult.from_value(1)),
... ),
... RequiresContextFutureResult.no_args,
... ) == IOSuccess(1)
>>> assert anyio.run(
... RequiresContextFutureResult.from_typecast(
... RequiresContext.from_value(FutureResult.from_failure(1)),
... ),
... RequiresContextFutureResult.no_args,
... ) == IOFailure(1)
inner_value (RequiresContext
[FutureResult
[TypeVar
(_NewValueType
), TypeVar
(_NewErrorType
)], TypeVar
(_EnvType
, contravariant=True)]) –
RequiresContextFutureResult
[TypeVar
(_NewValueType
), TypeVar
(_NewErrorType
), TypeVar
(_EnvType
, contravariant=True)]
Creates new container from RequiresContext
as a success unit.
>>> import anyio
>>> from returns.context import RequiresContext
>>> from returns.io import IOSuccess
>>> assert anyio.run(
... RequiresContextFutureResult.from_context(
... RequiresContext.from_value(1),
... ),
... RequiresContextFutureResult.no_args,
... ) == IOSuccess(1)
inner_value (RequiresContext
[TypeVar
(_NewValueType
), TypeVar
(_NewEnvType
)]) –
RequiresContextFutureResult
[TypeVar
(_NewValueType
), Any
, TypeVar
(_NewEnvType
)]
Creates new container from RequiresContext
as a failure unit.
>>> import anyio
>>> from returns.context import RequiresContext
>>> from returns.io import IOFailure
>>> assert anyio.run(
... RequiresContextFutureResult.from_failed_context(
... RequiresContext.from_value(1),
... ),
... RequiresContextFutureResult.no_args,
... ) == IOFailure(1)
inner_value (RequiresContext
[TypeVar
(_NewValueType
), TypeVar
(_NewEnvType
)]) –
RequiresContextFutureResult
[Any
, TypeVar
(_NewValueType
), TypeVar
(_NewEnvType
)]
Creates new container from RequiresContextResult
as a unit value.
>>> import anyio
>>> from returns.context import RequiresContextResult
>>> from returns.io import IOSuccess, IOFailure
>>> assert anyio.run(
... RequiresContextFutureResult.from_result_context(
... RequiresContextResult.from_value(1),
... ),
... RequiresContextFutureResult.no_args,
... ) == IOSuccess(1)
>>> assert anyio.run(
... RequiresContextFutureResult.from_result_context(
... RequiresContextResult.from_failure(1),
... ),
... RequiresContextFutureResult.no_args,
... ) == IOFailure(1)
inner_value (RequiresContextResult
[TypeVar
(_NewValueType
), TypeVar
(_NewErrorType
), TypeVar
(_NewEnvType
)]) –
RequiresContextFutureResult
[TypeVar
(_NewValueType
), TypeVar
(_NewErrorType
), TypeVar
(_NewEnvType
)]
Creates new container from RequiresContextIOResult
as a unit value.
>>> import anyio
>>> from returns.context import RequiresContextIOResult
>>> from returns.io import IOSuccess, IOFailure
>>> assert anyio.run(
... RequiresContextFutureResult.from_ioresult_context(
... RequiresContextIOResult.from_value(1),
... ),
... RequiresContextFutureResult.no_args,
... ) == IOSuccess(1)
>>> assert anyio.run(
... RequiresContextFutureResult.from_ioresult_context(
... RequiresContextIOResult.from_failure(1),
... ),
... RequiresContextFutureResult.no_args,
... ) == IOFailure(1)
inner_value (RequiresContextIOResult
[TypeVar
(_NewValueType
), TypeVar
(_NewErrorType
), TypeVar
(_NewEnvType
)]) –
RequiresContextFutureResult
[TypeVar
(_NewValueType
), TypeVar
(_NewErrorType
), TypeVar
(_NewEnvType
)]
Creates new container with successful FutureResult
as a unit value.
>>> import anyio
>>> from returns.context import RequiresContextFutureResult
>>> from returns.io import IOSuccess
>>> assert anyio.run(RequiresContextFutureResult.from_value(1)(
... RequiresContextFutureResult.no_args,
... ).awaitable) == IOSuccess(1)
inner_value (TypeVar
(_FirstType
)) –
RequiresContextFutureResult
[TypeVar
(_FirstType
), Any
, Any
]
Creates new container with failed FutureResult
as a unit value.
>>> import anyio
>>> from returns.context import RequiresContextFutureResult
>>> from returns.io import IOFailure
>>> assert anyio.run(RequiresContextFutureResult.from_failure(1)(
... RequiresContextFutureResult.no_args,
... ).awaitable) == IOFailure(1)
inner_value (TypeVar
(_FirstType
)) –
RequiresContextFutureResult
[Any
, TypeVar
(_FirstType
), Any
]
Alias for a popular case when Result
has Exception
as error type.
alias of RequiresContextFutureResult
[_ValueType
, Exception
, _EnvType
]
Sometimes RequiresContextFutureResult is too long to type.
inner_value (Callable
[[TypeVar
(_EnvType
, contravariant=True)], FutureResult
[TypeVar
(_ValueType
, covariant=True), TypeVar
(_ErrorType
, covariant=True)]]) –
Alias to save you some typing. Uses Exception
as error type.
alias of RequiresContextFutureResult
[_ValueType
, Exception
, _EnvType
]