معرفی شرکت ها

تبلیغات ما

مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.

مشاهده بیشتر

تبلیغات ما

مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.

مشاهده بیشتر

تبلیغات ما

مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.

مشاهده بیشتر

تبلیغات ما

مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.

مشاهده بیشتر

تبلیغات ما

مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.

مشاهده بیشتر

توضیحات

Asynchronous message handler between Process/Thread and asyncio event loop.

ویژگی	مقدار
سیستم عامل	-
نام فایل	async-message-handler-0.1.1
نام	async-message-handler
نسخه کتابخانه	0.1.1
نگهدارنده	[]
ایمیل نگهدارنده	[]
نویسنده	Mehmet Öztürk
ایمیل نویسنده	mehmetozturk4705@gmail.com
آدرس صفحه اصلی	https://github.com/mehmetozturk4705/async_message_handler
آدرس اینترنتی	https://pypi.org/project/async-message-handler/
مجوز	MIT

## Asynchronous Message Handler This package is a niche message handler solution between asyncio event loop and processes/threads (Aka multiprocessing.Process/threading.Thread). You can install this package by pip install async-message-handler * AMH creates asynchronous connection between asyncio event loop and another python process/thread. ### How to use? Code below shows basic usage of message handler api. This message api is completely nonblocking in asyncio event loop. import time import asyncio import multiprocessing as mp from asynchronous_message_handler import ProcessCommandHandler, CommandContext, ProcessCommand, Events #Creating new command handler object. handler = ProcessCommandHandler(timeout=15) def sample_process(context:CommandContext): #You should initialize context to be bound. context.initialize() #Waits until new message, this operation is blocking for this process. #If you want it to be nonblocking use blocking=False parameter. command:ProcessCommand = context.get_next() print(command.get_payload()) #Sleep for 5 seconds. time.sleep(5) command.reply("Hello from process.") time.sleep(5) #Send message from process to asynchronous context. context.send_message("This is a late message from process.") #This is a sample event handler for new messages from process/thread. @handler.on(Events.NewMessage) def message_callback(message): print(message) async def main(): #This is asyncio context. response = await handler.command("Hello from asyncio.") print(response) #Waiting for a while for sample process to loop message demo. await asyncio.sleep(8) if __name__=="__main__": process = mp.Process(target=sample_process, args=(handler.get_command_context(),)) process.start() loop = asyncio.get_event_loop() loop.run_until_complete(main()) process.join()

نحوه نصب

نصب پکیج whl async-message-handler-0.1.1:

pip install async-message-handler-0.1.1.whl

نصب پکیج tar.gz async-message-handler-0.1.1:

pip install async-message-handler-0.1.1.tar.gz