- android - RelativeLayout 背景可绘制重叠内容
- android - 如何链接 cpufeatures lib 以获取 native android 库?
- java - OnItemClickListener 不起作用,但 OnLongItemClickListener 在自定义 ListView 中起作用
- java - Android 文件转字符串
我正在尝试使用 NetworkStream.ReadAsync() 来读取数据,但我找不到如何在调用后取消 ReadAsync()。对于背景,NetworkStream 由连接的 BluetoothClient 对象(来自 32Feet.NET 蓝牙库)提供给我。
我正在尝试的当前 get-it-working 代码如下。
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 标志设置为 false 并接收到数据,它将停止循环,但在接收到数据之前,它不会继续通过 ReadAsync() 行。我看不到如何在没有收到数据的情况下中止调用。
我知道 ReadAsync 有一个重载,它提供了一个 CancellationToken,但似乎由于 NetworkStream 没有覆盖默认的 ReadAsync 行为,因此 token 被忽略(参见 NetworkStream.ReadAsync with a cancellation token never cancels )。
我已经尝试关闭底层流,这导致等待的 ReadAsync 调用抛出 ObjectDisposedException,并且底层蓝牙连接也被关闭。理想情况下,我不想为了停止阅读而完全切断与设备的连接。这似乎不是一种干净的方式,而且感觉没有必要为了中断 va ReadAsync() 调用而拆除整个流。
有什么建议吗?
最佳答案
您无法取消 ReadAsync,因为内部调用是非托管的并且使用 IOCompletion 端口。您的选项如下。
关于c# - 如何在不关闭流的情况下取消 NetworkStream.ReadAsync,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/15273752/
我不确定我是否遗漏了什么或者 SslStream 中确实存在设计缺陷(可能还有其他可以包装内部流的流类)。 考虑这个伪代码: MyStream { Task ReadAsync() { ...
一段时间以来我一直在思考这个问题(并且知道这很愚蠢)。 我正在下载带有显示正常的 ProgressBar 的文件,但如何从 ReadAsync 流中获取数据进行保存? public static re
如果您不输入任何输入,为什么下面的代码永远不会完成,为什么即使在取消标记被取消后它仍然响应按下的键? // Set up a cancellation token var cancellationSo
我有以下代码(_ns 是一个 NetworkStream) await GetResponse(_ns); btnSend.Enabled = true; private async Task Get
我有一个 C# TcpClient 来异步读取数据。简化代码如下: public async Task StartReading(CancellationToken token) { // T
我以前使用过串行端口及其原始方法,如 BytesToRead、Read 和 Write。据说这些是不可靠的,我有很多忙等待我试图切换到它的异步方法。 我需要使用 2 个不同的超时时间从串口读取数据。第
我正在尝试使用 NetworkStream.ReadAsync() 来读取数据,但我找不到如何在调用后取消 ReadAsync()。对于背景,NetworkStream 由连接的 BluetoothC
当使用“SocketAsyncEventArgs”类和 ReadAsync 时,我应该将读取缓冲区放在哪里以及将发送缓冲区放在哪里?或者我只能一次阅读或发送而不是两者?我有点困惑。 最佳答案 我认为您
我正在尝试将下面的类转换为延迟返回文件。 public class ObservableFile2 : IObservable { private readonly IObservable s
试一试。使用单个按钮和按钮单击事件的以下代码设置新的 Windows 窗体应用程序: private async void button1_Click(object sender, EventArgs
当 NamedPipeServer 流从管道中读取任何数据时,它不会对 CancellationTokenSource.Cancel() 使用react 这是为什么? 如何限制我在服务器中等待来自客户
我正在使用 NetworkStream 和 TcpClient。 首先我设置我的 tcp 客户端: tcp = new TcpClient(AddressFamily.InterNetwork
NetworkStream.ReadAsync 什么时候任务完成?一旦接收到指定长度的数据? 如果是,它会返回 0 吗?然后 CancellationToken可以用作 ReadTimeout ,这是
在samples for the Cosmos DB SQL API , Database.ReadAsync() 有多种用途这似乎没有做任何有用的事情。该方法文档中的第二个注释并没有真正说明它可能用
在samples for the Cosmos DB SQL API , Database.ReadAsync() 有多种用途这似乎没有做任何有用的事情。该方法文档中的第二个注释并没有真正说明它可能用
我正在尝试在 .net 中使用 SerialPort 类。 我选择让我的服务保持异步,所以我在 SerialPort.BaseStream 上使用异步方法。 在我的异步方法中,我将一个 byte[]
鉴于以下情况: using System; using System.IO; using System.Threading; using System.Threading.Tasks; namespa
当调用 SQL Server 执行实际需要时间的操作时,SqlDataReader.ReadAsync() 会为我同步运行。有没有办法强制它异步运行,或者是我在 Task.Run() 中调用它的唯一选
我可以创建一个 MobileServiceClient 和 GetTable()至InsertAsync ,并查看如何将我的模型插入到 Azure 中的 Easy Table 表中。但是当我 Read
我正在尝试构建具有持久 TCP 连接的可扩展 服务器应用程序。我使用的序列化库是同步的,将其转换为APM会造成很大的开销(我已经测试过了)。 数据包的格式始终是数据包 ID 的一个字节,后跟几个 he
我是一名优秀的程序员,十分优秀!