Adds .apply method, refs #274

Author: sobolevn

returns/_generated/pointfree/apply.pyi

@@ -4,6 +4,7 @@ from returns.context import (
     RequiresContext,
     RequiresContextIOResult,
     RequiresContextResult,
+    RequiresContextFutureResult,
 )
 from returns.future import Future, FutureResult
 from returns.io import IO, IOResult
@@ -68,6 +69,20 @@ def _apply(
     ...
 
 
+@overload
+def _apply(
+    container: RequiresContextFutureResult[
+        _EnvType,
+        Callable[[_ValueType], _NewValueType],
+        _ErrorType,
+    ],
+) -> Callable[
+    [RequiresContextFutureResult[_EnvType, _ValueType, _ErrorType]],
+    RequiresContextFutureResult[_EnvType, _NewValueType, _ErrorType],
+]:
+    ...
+
+
 @overload
 def _apply(
     container: Result[

returns/context/requires_context_future_result.py

@@ -119,6 +119,42 @@ def map(  # noqa: WPS125
             lambda deps: self(deps).map(function),
         )
 
+    def apply(
+        self,
+        container: 'RequiresContextFutureResult['
+            '_EnvType, Callable[[_ValueType], _NewValueType], _ErrorType]',
+    ) -> 'RequiresContextFutureResult[_EnvType, _NewValueType, _ErrorType]':
+        """
+        Calls a wrapped function in a container on this container.
+
+        .. code:: python
+
+          >>> 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.empty,
+          ... ) == IOSuccess('ab')
+
+          >>> assert anyio.run(
+          ...    RequiresContextFutureResult.from_failure('a').apply(
+          ...        RequiresContextFutureResult.from_value(transform),
+          ...    ),
+          ...    RequiresContextFutureResult.empty,
+          ... ) == IOFailure('a')
+
+        """
+        return RequiresContextFutureResult(
+            lambda deps: self(deps).apply(container(deps)),
+        )
+
     def bind(
         self,
         function: Callable[
@@ -162,7 +198,7 @@ def bind(
         """
         return RequiresContextFutureResult(
             lambda deps: self(deps).bind(
-                lambda inner: function(inner)(deps),  # type: ignore
+                lambda inner: function(inner)(deps),  # type: ignore[misc]
             ),
         )
 
@@ -216,7 +252,7 @@ def rescue(
         """
         return RequiresContextFutureResult(
             lambda deps: self(deps).rescue(
-                lambda inner: function(inner)(deps),  # type: ignore
+                lambda inner: function(inner)(deps),  # type: ignore[misc]
             ),
         )
 

returns/context/requires_context_ioresult.py

@@ -252,7 +252,7 @@ def bind(
         """
         return RequiresContextIOResult(
             lambda deps: self(deps).bind(
-                lambda inner: function(inner)(deps),  # type: ignore
+                lambda inner: function(inner)(deps),  # type: ignore[misc]
             ),
         )
 
@@ -322,7 +322,7 @@ def bind_context(
         """
         return RequiresContextIOResult(
             lambda deps: self(deps).map(
-                lambda inner: function(inner)(deps),  # type: ignore
+                lambda inner: function(inner)(deps),  # type: ignore[misc]
             ),
         )
 
@@ -375,7 +375,7 @@ def bind_context_result(
         """
         return RequiresContextIOResult(
             lambda deps: self(deps).bind_result(
-                lambda inner: function(inner)(deps),  # type: ignore
+                lambda inner: function(inner)(deps),  # type: ignore[misc]
             ),
         )
 
@@ -524,7 +524,7 @@ def rescue(
         """
         return RequiresContextIOResult(
             lambda deps: self(deps).rescue(
-                lambda inner: function(inner)(deps),  # type: ignore
+                lambda inner: function(inner)(deps),  # type: ignore[misc]
             ),
         )
 

setup.cfg

@@ -148,6 +148,7 @@ warn_unreachable = True
 
 # We need this to debug `mypy` plugin:
 show_traceback = True
+show_error_codes = True
 
 
 [doc8]

typesafety/test_context/test_requires_context_future_result/test_requires_context_future_result.yml

@@ -8,6 +8,18 @@
     reveal_type(x.map(bool))  # N: Revealed type is 'returns.context.requires_context_future_result.RequiresContextFutureResult[builtins.str, builtins.bool*, builtins.float]'
 
 
+- case: requires_context_future_result_apply
+  disable_cache: true
+  main: |
+    from typing import Callable
+    from returns.context import RequiresContextFutureResult
+
+    x: RequiresContextFutureResult[str, int, float]
+    y: RequiresContextFutureResult[str, Callable[[int], bool], float]
+
+    reveal_type(x.apply(y))  # N: Revealed type is 'returns.context.requires_context_future_result.RequiresContextFutureResult[builtins.str, builtins.bool*, builtins.float]'
+
+
 - case: requires_context_future_result_bind
   disable_cache: true
   main: |

typesafety/test_pointfree/test_apply.yml

@@ -96,6 +96,18 @@
     reveal_type(apply(test))  # N: Revealed type is 'def (returns.context.requires_context_ioresult.RequiresContextIOResult[builtins.bool*, builtins.float*, builtins.str*]) -> returns.context.requires_context_ioresult.RequiresContextIOResult[builtins.bool*, builtins.int*, builtins.str*]'
 
 
+- case: apply_requires_context_future_result
+  disable_cache: true
+  main: |
+    from returns.pointfree import apply
+    from returns.context import RequiresContextFutureResult
+    from typing import Callable
+
+    test: RequiresContextFutureResult[bool, Callable[[float], int], str]
+
+    reveal_type(apply(test))  # N: Revealed type is 'def (returns.context.requires_context_future_result.RequiresContextFutureResult[builtins.bool*, builtins.float*, builtins.str*]) -> returns.context.requires_context_future_result.RequiresContextFutureResult[builtins.bool*, builtins.int*, builtins.str*]'
+
+
 - case: apply_future
   disable_cache: true
   main: |