Change functions of various arity returning Awaitable[T] to async functions returning T.

CHANGELOG.md

@@ -2,6 +2,13 @@
 
 <!-- changelogging: start -->
 
+## 0.3.0 (2022-08-17)
+
+### Changes
+
+- Change functions of various arity returning `Awaitable[T]` to async functions returning `T`.
+  ([#15](https://github.com/nekitdev/iters/pull/15))
+
 ## 0.2.0 (2022-08-15)
 
 ### Changes

README.md

@@ -48,7 +48,7 @@ Or by directly specifying it in the configuration like so:
 
 ```toml
 [tool.poetry.dependencies]
-iters = "^0.2.0"
+iters = "^0.3.0"
 ```
 
 Alternatively, you can add it directly from the source:

iters/__init__.py

@@ -6,7 +6,7 @@
 __title__ = "iters"
 __author__ = "nekitdev"
 __license__ = "MIT"
-__version__ = "0.2.0"
+__version__ = "0.3.0"
 
 from iters.async_iters import (
     AsyncIter,

iters/async_utils.py

@@ -4194,12 +4194,12 @@ def async_wait_concurrent_bound(
         return async_flat_map(async_wait_concurrent, async_chunks(bound, iterable))
 
     def async_map_concurrent(
-        function: Unary[T, Awaitable[U]], iterable: AnyIterable[T]
+        function: AsyncUnary[T, U], iterable: AnyIterable[T]
     ) -> AsyncIterator[U]:
         return async_wait_concurrent(async_map(function, iterable))
 
     def async_map_concurrent_bound(
-        bound: int, function: Unary[T, Awaitable[U]], iterable: AnyIterable[T]
+        bound: int, function: AsyncUnary[T, U], iterable: AnyIterable[T]
     ) -> AsyncIterator[U]:
         return async_wait_concurrent_bound(bound, async_map(function, iterable))
 

iters/typing.py

@@ -131,13 +131,13 @@
 Predicate = Unary[T, MaybeBool]
 Selectors = Iterable[MaybeBool]
 
-AsyncPredicate = Unary[T, Awaitable[MaybeBool]]
+AsyncPredicate = AsyncUnary[T, MaybeBool]
 AsyncSelectors = AsyncIterable[MaybeBool]
 
 AnySelectors = Union[AsyncSelectors, Selectors]
 
 Compare = Binary[T, U, MaybeBool]
-AsyncCompare = Binary[T, U, Awaitable[MaybeBool]]
+AsyncCompare = AsyncBinary[T, U, MaybeBool]
 
 EmptyTuple = Tuple[()]
 

pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "iters"
-version = "0.2.0"
+version = "0.3.0"
 description = "Composable external iteration."
 authors = ["nekitdev"]
 license = "MIT"
@@ -131,7 +131,7 @@ warn_unused_ignores = false  # compatibility
 
 [tool.changelogging]
 name = "iters"
-version = "0.2.0"
+version = "0.3.0"
 url = "https://github.com/nekitdev/iters"
 directory = "changes"
 output = "CHANGELOG.md"