automatic import of python-aiochannel

3 files changed, 452 insertions, 0 deletions

diff --git a/.gitignore b/.gitignore
index e69de29..77409ed 100644
--- a/.gitignore
+++ b/.gitignore
@@ -0,0 +1 @@
+/aiochannel-1.2.1.tar.gz
diff --git a/python-aiochannel.spec b/python-aiochannel.spec
new file mode 100644
index 0000000..737223e
--- /dev/null
+++ b/python-aiochannel.spec
@@ -0,0 +1,450 @@
+%global _empty_manifest_terminate_build 0
+Name:		python-aiochannel
+Version:	1.2.1
+Release:	1
+Summary:	asyncio Channels (closable queues) inspired by golang
+License:	Apache-2.0
+URL:		https://github.com/tbug/aiochannel
+Source0:	https://mirrors.nju.edu.cn/pypi/web/packages/5c/3c/15a116826cef1e3db70f83f9e8edca3f05ed720b2008ff45b8d014546536/aiochannel-1.2.1.tar.gz
+BuildArch:	noarch
+
+
+%description
+# aiochannel - AsyncIO Channel
+
+[![Build Status](https://github.com/tbug/aiochannel/actions/workflows/test.yml/badge.svg)][Build Status]
+[![Stable Version](https://img.shields.io/pypi/v/aiochannel?label=stable)][PyPI Releases]
+[![Python Versions](https://img.shields.io/pypi/pyversions/aiochannel)][PyPI]
+[![Download Stats](https://img.shields.io/pypi/dm/aiochannel)](https://pypistats.org/packages/aiochannel)
+
+Channel concept for asyncio.
+
+
+## Install
+
+```
+pip install aiochannel
+```
+
+## Changelog
+
+[Changelog]
+
+## Usage
+
+### Basics
+
+`Channel` has a very similar API to `asyncio.Queue`.
+The key difference is that a channel is only considered
+"done" when it has been both closed and drained, so calling `.join()`
+on a channel will wait for it to be both closed and drained (Unlike
+`Queue` which will return from `.join()` once the queue is empty).
+
+**NOTE:** Closing a channel is permanent. You cannot open it again.
+
+```python
+import asyncio
+from aiochannel import Channel
+
+# ...
+
+async def main():
+    # A Channel takes a max queue size and an loop
+    # both optional. loop is not recommended as
+    # in asyncio is phasing out explicitly passed event-loop
+    my_channel: Channel[str] = Channel(100)
+
+    # You add items to the channel with
+    await my_channel.put("my item")
+    # Note that this can throw ChannelClosed if the channel
+    # is closed, during the attempt at adding the item
+    # to the channel. Also note that .put() will block until
+    # it can successfully add the item.
+
+
+    # Retrieving is done with
+    my_item = await my_channel.get()
+    # Note that this can also throw ChannelClosed if the
+    # channel is closed before or during retrival.
+    # .get() will block until an item can be retrieved.
+
+    # Note that this requires someone else to close and drain
+    # the channel.
+    # Lastly, you can close a channel with `my_channel.close()`
+    # In this example, the event-loop call this asynchronously
+    asyncio.get_event_loop().call_later(0.1, my_channel.close)
+
+    # You can wait for the channel to be closed and drained:
+    await my_channel.join()
+
+    # Every call to .put() after .close() will fail with
+    # a ChannelClosed.
+    # you can check if a channel is marked for closing with
+    if my_channel.closed():
+        print ("Channel is closed")
+
+asyncio.run(main())
+```
+
+Like the `asyncio.Queue` you can also call non-async get and put:
+
+<!--pytest.mark.skip-->
+
+```python
+    # non-async version of put
+    my_channel.put_nowait(item)
+    # This either returns None,
+    # or raises ChannelClosed or ChannelFull
+
+    # non-async version of get
+    my_channel.get_nowait()
+    # This either returns the next item from the channel
+    # or raises ChannelEmpty or ChannelClosed
+    # (Note that ChannelClosed emplies that the channel
+    # is empty, but also that is will never fill again)
+```
+
+As of `0.2.0` `Channel` also implements the async iterator protocol.
+You can now use `async for` to iterate over the channel until it
+closes, without having to deal with `ChannelClosed` exceptions.
+
+<!--pytest.mark.skip-->
+
+```python
+    # the channel might contain data here
+    async for item in channel:
+        print(item)
+    # the channel is closed and empty here
+```
+
+which is functionally equivalent to
+
+<!--pytest.mark.skip-->
+
+```python
+    while True:
+        try:
+            data = yield from channel.get()
+        except ChannelClosed:
+            break
+        # process data here
+```
+
+  [PyPI]: https://pypi.org/project/aiochannel
+  [PyPI Releases]: https://pypi.org/project/aiochannel/#history
+  [Github]: https://github.com/tbug/aiochannel
+  [Changelog]: https://github.com/tbug/aiochannel/blob/master/CHANGELOG.md
+  [Issue Tracker]: https://github.com/tbug/aiochannel/issues
+  [Build Status]: https://github.com/tbug/aiochannel/actions/workflows/test.yml
+
+
+%package -n python3-aiochannel
+Summary:	asyncio Channels (closable queues) inspired by golang
+Provides:	python-aiochannel
+BuildRequires:	python3-devel
+BuildRequires:	python3-setuptools
+BuildRequires:	python3-pip
+%description -n python3-aiochannel
+# aiochannel - AsyncIO Channel
+
+[![Build Status](https://github.com/tbug/aiochannel/actions/workflows/test.yml/badge.svg)][Build Status]
+[![Stable Version](https://img.shields.io/pypi/v/aiochannel?label=stable)][PyPI Releases]
+[![Python Versions](https://img.shields.io/pypi/pyversions/aiochannel)][PyPI]
+[![Download Stats](https://img.shields.io/pypi/dm/aiochannel)](https://pypistats.org/packages/aiochannel)
+
+Channel concept for asyncio.
+
+
+## Install
+
+```
+pip install aiochannel
+```
+
+## Changelog
+
+[Changelog]
+
+## Usage
+
+### Basics
+
+`Channel` has a very similar API to `asyncio.Queue`.
+The key difference is that a channel is only considered
+"done" when it has been both closed and drained, so calling `.join()`
+on a channel will wait for it to be both closed and drained (Unlike
+`Queue` which will return from `.join()` once the queue is empty).
+
+**NOTE:** Closing a channel is permanent. You cannot open it again.
+
+```python
+import asyncio
+from aiochannel import Channel
+
+# ...
+
+async def main():
+    # A Channel takes a max queue size and an loop
+    # both optional. loop is not recommended as
+    # in asyncio is phasing out explicitly passed event-loop
+    my_channel: Channel[str] = Channel(100)
+
+    # You add items to the channel with
+    await my_channel.put("my item")
+    # Note that this can throw ChannelClosed if the channel
+    # is closed, during the attempt at adding the item
+    # to the channel. Also note that .put() will block until
+    # it can successfully add the item.
+
+
+    # Retrieving is done with
+    my_item = await my_channel.get()
+    # Note that this can also throw ChannelClosed if the
+    # channel is closed before or during retrival.
+    # .get() will block until an item can be retrieved.
+
+    # Note that this requires someone else to close and drain
+    # the channel.
+    # Lastly, you can close a channel with `my_channel.close()`
+    # In this example, the event-loop call this asynchronously
+    asyncio.get_event_loop().call_later(0.1, my_channel.close)
+
+    # You can wait for the channel to be closed and drained:
+    await my_channel.join()
+
+    # Every call to .put() after .close() will fail with
+    # a ChannelClosed.
+    # you can check if a channel is marked for closing with
+    if my_channel.closed():
+        print ("Channel is closed")
+
+asyncio.run(main())
+```
+
+Like the `asyncio.Queue` you can also call non-async get and put:
+
+<!--pytest.mark.skip-->
+
+```python
+    # non-async version of put
+    my_channel.put_nowait(item)
+    # This either returns None,
+    # or raises ChannelClosed or ChannelFull
+
+    # non-async version of get
+    my_channel.get_nowait()
+    # This either returns the next item from the channel
+    # or raises ChannelEmpty or ChannelClosed
+    # (Note that ChannelClosed emplies that the channel
+    # is empty, but also that is will never fill again)
+```
+
+As of `0.2.0` `Channel` also implements the async iterator protocol.
+You can now use `async for` to iterate over the channel until it
+closes, without having to deal with `ChannelClosed` exceptions.
+
+<!--pytest.mark.skip-->
+
+```python
+    # the channel might contain data here
+    async for item in channel:
+        print(item)
+    # the channel is closed and empty here
+```
+
+which is functionally equivalent to
+
+<!--pytest.mark.skip-->
+
+```python
+    while True:
+        try:
+            data = yield from channel.get()
+        except ChannelClosed:
+            break
+        # process data here
+```
+
+  [PyPI]: https://pypi.org/project/aiochannel
+  [PyPI Releases]: https://pypi.org/project/aiochannel/#history
+  [Github]: https://github.com/tbug/aiochannel
+  [Changelog]: https://github.com/tbug/aiochannel/blob/master/CHANGELOG.md
+  [Issue Tracker]: https://github.com/tbug/aiochannel/issues
+  [Build Status]: https://github.com/tbug/aiochannel/actions/workflows/test.yml
+
+
+%package help
+Summary:	Development documents and examples for aiochannel
+Provides:	python3-aiochannel-doc
+%description help
+# aiochannel - AsyncIO Channel
+
+[![Build Status](https://github.com/tbug/aiochannel/actions/workflows/test.yml/badge.svg)][Build Status]
+[![Stable Version](https://img.shields.io/pypi/v/aiochannel?label=stable)][PyPI Releases]
+[![Python Versions](https://img.shields.io/pypi/pyversions/aiochannel)][PyPI]
+[![Download Stats](https://img.shields.io/pypi/dm/aiochannel)](https://pypistats.org/packages/aiochannel)
+
+Channel concept for asyncio.
+
+
+## Install
+
+```
+pip install aiochannel
+```
+
+## Changelog
+
+[Changelog]
+
+## Usage
+
+### Basics
+
+`Channel` has a very similar API to `asyncio.Queue`.
+The key difference is that a channel is only considered
+"done" when it has been both closed and drained, so calling `.join()`
+on a channel will wait for it to be both closed and drained (Unlike
+`Queue` which will return from `.join()` once the queue is empty).
+
+**NOTE:** Closing a channel is permanent. You cannot open it again.
+
+```python
+import asyncio
+from aiochannel import Channel
+
+# ...
+
+async def main():
+    # A Channel takes a max queue size and an loop
+    # both optional. loop is not recommended as
+    # in asyncio is phasing out explicitly passed event-loop
+    my_channel: Channel[str] = Channel(100)
+
+    # You add items to the channel with
+    await my_channel.put("my item")
+    # Note that this can throw ChannelClosed if the channel
+    # is closed, during the attempt at adding the item
+    # to the channel. Also note that .put() will block until
+    # it can successfully add the item.
+
+
+    # Retrieving is done with
+    my_item = await my_channel.get()
+    # Note that this can also throw ChannelClosed if the
+    # channel is closed before or during retrival.
+    # .get() will block until an item can be retrieved.
+
+    # Note that this requires someone else to close and drain
+    # the channel.
+    # Lastly, you can close a channel with `my_channel.close()`
+    # In this example, the event-loop call this asynchronously
+    asyncio.get_event_loop().call_later(0.1, my_channel.close)
+
+    # You can wait for the channel to be closed and drained:
+    await my_channel.join()
+
+    # Every call to .put() after .close() will fail with
+    # a ChannelClosed.
+    # you can check if a channel is marked for closing with
+    if my_channel.closed():
+        print ("Channel is closed")
+
+asyncio.run(main())
+```
+
+Like the `asyncio.Queue` you can also call non-async get and put:
+
+<!--pytest.mark.skip-->
+
+```python
+    # non-async version of put
+    my_channel.put_nowait(item)
+    # This either returns None,
+    # or raises ChannelClosed or ChannelFull
+
+    # non-async version of get
+    my_channel.get_nowait()
+    # This either returns the next item from the channel
+    # or raises ChannelEmpty or ChannelClosed
+    # (Note that ChannelClosed emplies that the channel
+    # is empty, but also that is will never fill again)
+```
+
+As of `0.2.0` `Channel` also implements the async iterator protocol.
+You can now use `async for` to iterate over the channel until it
+closes, without having to deal with `ChannelClosed` exceptions.
+
+<!--pytest.mark.skip-->
+
+```python
+    # the channel might contain data here
+    async for item in channel:
+        print(item)
+    # the channel is closed and empty here
+```
+
+which is functionally equivalent to
+
+<!--pytest.mark.skip-->
+
+```python
+    while True:
+        try:
+            data = yield from channel.get()
+        except ChannelClosed:
+            break
+        # process data here
+```
+
+  [PyPI]: https://pypi.org/project/aiochannel
+  [PyPI Releases]: https://pypi.org/project/aiochannel/#history
+  [Github]: https://github.com/tbug/aiochannel
+  [Changelog]: https://github.com/tbug/aiochannel/blob/master/CHANGELOG.md
+  [Issue Tracker]: https://github.com/tbug/aiochannel/issues
+  [Build Status]: https://github.com/tbug/aiochannel/actions/workflows/test.yml
+
+
+%prep
+%autosetup -n aiochannel-1.2.1
+
+%build
+%py3_build
+
+%install
+%py3_install
+install -d -m755 %{buildroot}/%{_pkgdocdir}
+if [ -d doc ]; then cp -arf doc %{buildroot}/%{_pkgdocdir}; fi
+if [ -d docs ]; then cp -arf docs %{buildroot}/%{_pkgdocdir}; fi
+if [ -d example ]; then cp -arf example %{buildroot}/%{_pkgdocdir}; fi
+if [ -d examples ]; then cp -arf examples %{buildroot}/%{_pkgdocdir}; fi
+pushd %{buildroot}
+if [ -d usr/lib ]; then
+	find usr/lib -type f -printf "/%h/%f\n" >> filelist.lst
+fi
+if [ -d usr/lib64 ]; then
+	find usr/lib64 -type f -printf "/%h/%f\n" >> filelist.lst
+fi
+if [ -d usr/bin ]; then
+	find usr/bin -type f -printf "/%h/%f\n" >> filelist.lst
+fi
+if [ -d usr/sbin ]; then
+	find usr/sbin -type f -printf "/%h/%f\n" >> filelist.lst
+fi
+touch doclist.lst
+if [ -d usr/share/man ]; then
+	find usr/share/man -type f -printf "/%h/%f.gz\n" >> doclist.lst
+fi
+popd
+mv %{buildroot}/filelist.lst .
+mv %{buildroot}/doclist.lst .
+
+%files -n python3-aiochannel -f filelist.lst
+%dir %{python3_sitelib}/*
+
+%files help -f doclist.lst
+%{_docdir}/*
+
+%changelog
+* Mon May 29 2023 Python_Bot <Python_Bot@openeuler.org> - 1.2.1-1
+- Package Spec generated
diff --git a/sources b/sources
new file mode 100644
index 0000000..6e4df49
--- /dev/null
+++ b/sources
@@ -0,0 +1 @@
+c62eedf2a2789e5742ed35dea1526d52  aiochannel-1.2.1.tar.gz