//------------------------------------------------------------------------------ // 此代码版权(除特别声明或在XREF结尾的命名空间的代码)归作者本人若汝棋茗所有 // 源代码使用协议遵循本仓库的开源协议及附加协议,若本仓库没有设置,则按MIT开源协议授权 // CSDN博客:https://blog.csdn.net/qq_40374647 // 哔哩哔哩视频:https://space.bilibili.com/94253567 // Gitee源代码仓库:https://gitee.com/RRQM_Home // Github源代码仓库:https://github.com/RRQM // API首页:https://www.yuque.com/rrqm/touchsocket/index // 交流QQ群:234762506 // 感谢您的下载和使用 //------------------------------------------------------------------------------ //------------------------------------------------------------------------------ using System; using System.Threading; using System.Threading.Tasks; using TouchSocket.Core; namespace TouchSocket.Sockets { /// /// 等待型客户端。 /// public interface IWaitingClient : IWaitSender,IDisposable where TClient : IClient, IDefaultSender, ISender { /// /// 等待设置。 /// public WaitingOptions WaitingOptions { get;} /// /// 客户端终端 /// TClient Client { get; } /// /// 发送字节流 /// /// 数据缓存区 /// 偏移 /// 长度 /// 超时时间 /// 取消令箭 /// 客户端没有连接 /// 发送数据超长 /// 其他异常 /// 返回的数据 ResponsedData SendThenResponse(byte[] buffer, int offset, int length, int timeout = 1000 * 5, CancellationToken token = default); /// /// 发送字节流 /// /// 数据缓存区 /// 超时时间 /// 取消令箭 /// 客户端没有连接 /// 发送数据超长 /// 其他异常 /// 返回的数据 ResponsedData SendThenResponse(byte[] buffer, int timeout = 1000 * 5, CancellationToken token = default); /// /// 发送流中的有效数据 /// /// 数据块载体 /// 超时时间 /// 取消令箭 /// 客户端没有连接 /// 发送数据超长 /// 其他异常 /// 返回的数据 ResponsedData SendThenResponse(ByteBlock byteBlock, int timeout = 1000 * 5, CancellationToken token = default); /// /// 异步发送 /// /// 数据缓存区 /// 偏移 /// 长度 /// 超时时间 /// 取消令箭 /// 客户端没有连接 /// 发送数据超长 /// 其他异常 /// 返回的数据 Task SendThenResponseAsync(byte[] buffer, int offset, int length, int timeout = 1000 * 5, CancellationToken token = default); /// /// 异步发送 /// /// 数据缓存区 /// 超时时间 /// 取消令箭 /// 客户端没有连接 /// 发送数据超长 /// 其他异常 /// 返回的数据 Task SendThenResponseAsync(byte[] buffer, int timeout = 1000 * 5, CancellationToken token = default); /// /// 异步发送 /// /// 数据块载体 /// 超时时间 /// 取消令箭 /// 客户端没有连接 /// 发送数据超长 /// 其他异常 /// 返回的数据 Task SendThenResponseAsync(ByteBlock byteBlock, int timeout = 1000 * 5, CancellationToken token = default); } }