कैसे धारा

Question

मैं NetworkStream.ReadAsync उपयोग करने के लिए() डेटा पढ़ने की कोशिश कर रहा हूँ बंद किए बिना NetworkStream.ReadAsync रद्द करने के लिए, लेकिन मैं ReadAsync() एक बार कहा जाता है बंद करने का तरीका नहीं मिल रही है। पृष्ठभूमि के लिए, नेटवर्कस्ट्रीम मुझे एक कनेक्टेड ब्लूटूथ क्लाइंट ऑब्जेक्ट (32Feet.NET ब्लूटूथ लाइब्रेरी से) द्वारा प्रदान किया जाता है।

वर्तमान get-यह काम कोड मैं कोशिश कर रहा हूँ के नीचे है।

int bytesRead; 

while (this.continueReading) 
{ 
    bytesRead = await this.stream.ReadAsync(this.buffer, 0, (int)this.buffer.Length); 

    Console.WriteLine("Received {0} bytes", bytesRead); 
} 

Console.WriteLine("Receive loop has ended"); 

कोड ठीक प्राप्त डेटा काम करता है, और continueReading ध्वज गलत पर सेट है और डेटा प्राप्त होता है पाशन बंद हो जाएगा, लेकिन डेटा प्राप्त होने तक यह अतीत ReadAsync() लाइन आगे बढ़ना नहीं होंगे। मैं नहीं देख सकता कि डेटा प्राप्त किए बिना कॉल को कैसे रद्द किया जाए।

मुझे पता है ReadAsync की एक अधिभार जो एक CancellationToken प्रदान करता है कि वहाँ हूँ, लेकिन ऐसा लगता है कि के रूप में NetworkStream डिफ़ॉल्ट ReadAsync व्यवहार पर हावी नहीं होता, टोकन नजरअंदाज कर दिया है (NetworkStream.ReadAsync with a cancellation token never cancels देखें)।

मैं अंतर्निहित धारा को बंद करने की कोशिश की है, और इस ObjectDisposedException फेंकने के लिए इंतजार कर रहे ReadAsync कॉल का कारण बनता है, और अंतर्निहित ब्लूटूथ कनेक्शन भी बंद कर दिया जाता है। आदर्श रूप से मैं सिर्फ पढ़ने के लिए डिवाइस के साथ कनेक्शन को पूरी तरह से अलग नहीं करना चाहता हूं। यह ऐसा करने का एक साफ तरीका प्रतीत नहीं होता है, और पूरी तरह से va ReadAsync() कॉल को बाधित करने के लिए पूरी स्ट्रीम को फाड़ने के लिए अनावश्यक लगता है।

कोई सलाह?

Answer 1

आप NetworkStream.Read (या ReadAsync) के चारों ओर एक async आवरण है, जो भी एक cancellationtoken है कि आप पर नजर रखने और अपने आप को सम्मान कर सकते हैं प्राप्त करता है लागू कर सकते हैं। कुछ इस तरह:

Task MyCancelableNetworkStreamReadAsync(NetworkStream stream, CancellationToken ct) 
{ 
... 
if(this.stream.CanRead) 
{ 
    do 
    { 
    //check ct.IsCancellationRequested and act as needed 
    bytesRead = await this.stream.ReadAsync(this.buffer, 0, (int)this.buffer.Length); 
    } 
    while(myNetworkStream.DataAvailable); 
} 

कृपया ध्यान दें कि मैं केवल विचार वर्णन करने के लिए कोशिश कर रहा हूँ और आप Task<TResult> लौटने, साथ ही है कि क्या करते हैं के लिए विचार करने के लिए wnt सकता है {} जबकि पाश, किसी भी प्रकार या सफाई, आदि - सभी आपकी जरूरतों के हिसाब से।

मैं स्टीफन टब How do I cancel non-cancelable async operations? द्वारा लेख पर आपका ध्यान भी इंगित करता हूं और साथ ही साथ संयोजन के विस्तार के साथ भी वह ध्यान देता है।

Answer 2

आप ReadAsync रद्द नहीं कर सकते, क्योंकि आंतरिक कॉल अप्रबंधित और IOCompletion बंदरगाहों का उपयोग करता .. आपके विकल्प इस प्रकार हैं।

1. सॉकेट का उपयोग करें। शटडाउन()। यह ऑपरेशनअबॉर्टेड की सॉकेट त्रुटि के साथ ReadAsync को वापस कर देगा।
2. पढ़ने के लिए समय-समय पर प्रतीक्षा करें।
3. जांच करें कि डेटा सॉकेट से पढ़ने से पहले उपलब्ध है।

Answer 3

मैं होने टास्क async कॉल और इस तरह का इंतजार बयान के बीच रद्द टोकन कॉल के लिए इंतजार द्वारा रद्द करने के प्रबंध कर रहा हूँ:

try { 

.... 

Task<int> readTask = input.ReadAsync(buffer, 0, buffer.Length); 
readTask.Wait(myCancellationToken); 
int readBytes= await readTask; 

.... 

} 
catch (OperationCanceledException e) 
{ 
    // handle cancellation 
}