कैसे पता चलेगा कि कौन सा कोरआउटिन asyncio.wait()

Question

के साथ किया गया था मेरे पास दो StreamReader ऑब्जेक्ट्स हैं और इन्हें लूप में पढ़ना है। मैं asyncio.wait उपयोग कर रहा हूँ इस तरह:

done, pending = await asyncio.wait(
    [reader.read(1000), freader.read(1000)], 
    return_when=asyncio.FIRST_COMPLETED) 

अब done.pop() मुझे भविष्य है कि पहले समाप्त हो देता है। समस्या यह है कि मुझे नहीं पता कि read() ऑपरेशन कैसे पूरा हुआ। मैंने [reader.read(1000), freader.read(1000)] को tasks चर में डालने और उन लोगों के साथ किए गए भविष्य की तुलना करने की कोशिश की। लेकिन ऐसा गलत लगता है क्योंकि पूरा भविष्य मूल कार्यों में से कोई भी बराबर नहीं है। तो मुझे यह पता लगाना चाहिए कि कौन सा कोरआउट समाप्त हो गया था?

Answer 1

आपको प्रत्येक .read कॉल के लिए एक अलग कार्य बनाने की आवश्यकता है, और उन कार्यों को .wait पर पास करें। फिर आप देख सकते हैं कि कार्य परिणाम में हैं।

reader_task = asyncio.ensure_future(reader.read(1000)) 
... 

done, pending = await asyncio.wait(
    [reader_task, ...], 
    return_when=asyncio.FIRST_COMPLETED, 
) 

if reader_task in done: 
    ... 

... 

उदा। websockets दस्तावेज़ीकरण से।