Merge pull request #50 from vkottler/dev/1.0.2-initialized-event

1.0.2 - Add connection-initialization event
vkottler · Apr 7, 2023 · 55d2b30 · 55d2b30
2 parents 740edd1 + c06a236
commit 55d2b30
Show file tree

Hide file tree

Showing 5 changed files with 8 additions and 6 deletions.
diff --git a/README.md b/README.md
@@ -2,11 +2,11 @@
     =====================================
     generator=datazen
     version=3.1.0
-    hash=510e3397b6792736f91654e3847ccf43
+    hash=67c11985b808ec63e99497bfbb8b0c15
     =====================================
 -->
 
-# runtimepy ([1.0.1](https://pypi.org/project/runtimepy/))
+# runtimepy ([1.0.2](https://pypi.org/project/runtimepy/))
 
 [![python](https://img.shields.io/pypi/pyversions/runtimepy.svg)](https://pypi.org/project/runtimepy/)
 ![Build Status](https://github.com/vkottler/runtimepy/workflows/Python%20Package/badge.svg)

diff --git a/local/variables/package.yaml b/local/variables/package.yaml
@@ -1,5 +1,5 @@
 ---
 major: 1
 minor: 0
-patch: 1
+patch: 2
 entry: runtimepy
diff --git a/pyproject.toml b/pyproject.toml
@@ -4,7 +4,7 @@ build-backend = "setuptools.build_meta:__legacy__"
 
 [project]
 name = "runtimepy"
-version = "1.0.1"
+version = "1.0.2"
 description = "A framework for implementing Python services."
 readme = "README.md"
 requires-python = ">=3.7"

diff --git a/runtimepy/__init__.py b/runtimepy/__init__.py
@@ -1,7 +1,7 @@
 # =====================================
 # generator=datazen
 # version=3.1.0
-# hash=a869e3ab405cc0055ec5bb7a73182b8b
+# hash=f046ffa060de0f7a1c7e94b145c190e2
 # =====================================
 
 """
@@ -10,4 +10,4 @@
 
 DESCRIPTION = "A framework for implementing Python services."
 PKG_NAME = "runtimepy"
-VERSION = "1.0.1"
+VERSION = "1.0.2"
diff --git a/runtimepy/net/connection.py b/runtimepy/net/connection.py
@@ -34,6 +34,7 @@ def __init__(self, logger: _LoggerType) -> None:
         self.tx_binary_hwm: int = 0
 
         self._tasks: _List[_asyncio.Task[None]] = []
+        self.initialized = _asyncio.Event()
         self.init()
 
     def init(self) -> None:
@@ -111,6 +112,7 @@ async def _async_init(self) -> None:
 
         if not await self.async_init():
             self.disable("init failed")
+        self.initialized.set()
 
     async def process(self, stop_sig: _asyncio.Event = None) -> None:
         """