123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111 |
- //------------------------------------------------------------------------------
- // 此代码版权(除特别声明或在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
- {
- /// <summary>
- /// 等待型客户端。
- /// </summary>
- public interface IWaitingClient<TClient> : IWaitSender,IDisposable where TClient : IClient, IDefaultSender, ISender
- {
- /// <summary>
- /// 等待设置。
- /// </summary>
- public WaitingOptions WaitingOptions { get;}
- /// <summary>
- /// 客户端终端
- /// </summary>
- TClient Client { get; }
- /// <summary>
- /// 发送字节流
- /// </summary>
- /// <param name="buffer">数据缓存区</param>
- /// <param name="offset">偏移</param>
- /// <param name="length">长度</param>
- /// <param name="timeout">超时时间</param>
- /// <param name="token">取消令箭</param>
- /// <exception cref="NotConnectedException">客户端没有连接</exception>
- /// <exception cref="OverlengthException">发送数据超长</exception>
- /// <exception cref="Exception">其他异常</exception>
- /// <returns>返回的数据</returns>
- ResponsedData SendThenResponse(byte[] buffer, int offset, int length, int timeout = 1000 * 5, CancellationToken token = default);
- /// <summary>
- /// 发送字节流
- /// </summary>
- /// <param name="buffer">数据缓存区</param>
- /// <param name="timeout">超时时间</param>
- /// <param name="token">取消令箭</param>
- /// <exception cref="NotConnectedException">客户端没有连接</exception>
- /// <exception cref="OverlengthException">发送数据超长</exception>
- /// <exception cref="Exception">其他异常</exception>
- /// <returns>返回的数据</returns>
- ResponsedData SendThenResponse(byte[] buffer, int timeout = 1000 * 5, CancellationToken token = default);
- /// <summary>
- /// 发送流中的有效数据
- /// </summary>
- /// <param name="byteBlock">数据块载体</param>
- /// <param name="timeout">超时时间</param>
- /// <param name="token">取消令箭</param>
- /// <exception cref="NotConnectedException">客户端没有连接</exception>
- /// <exception cref="OverlengthException">发送数据超长</exception>
- /// <exception cref="Exception">其他异常</exception>
- /// <returns>返回的数据</returns>
- ResponsedData SendThenResponse(ByteBlock byteBlock, int timeout = 1000 * 5, CancellationToken token = default);
- /// <summary>
- /// 异步发送
- /// </summary>
- /// <param name="buffer">数据缓存区</param>
- /// <param name="offset">偏移</param>
- /// <param name="length">长度</param>
- /// <param name="timeout">超时时间</param>
- /// <param name="token">取消令箭</param>
- /// <exception cref="NotConnectedException">客户端没有连接</exception>
- /// <exception cref="OverlengthException">发送数据超长</exception>
- /// <exception cref="Exception">其他异常</exception>
- /// <returns>返回的数据</returns>
- Task<ResponsedData> SendThenResponseAsync(byte[] buffer, int offset, int length, int timeout = 1000 * 5, CancellationToken token = default);
- /// <summary>
- /// 异步发送
- /// </summary>
- /// <param name="buffer">数据缓存区</param>
- /// <param name="timeout">超时时间</param>
- /// <param name="token">取消令箭</param>
- /// <exception cref="NotConnectedException">客户端没有连接</exception>
- /// <exception cref="OverlengthException">发送数据超长</exception>
- /// <exception cref="Exception">其他异常</exception>
- /// <returns>返回的数据</returns>
- Task<ResponsedData> SendThenResponseAsync(byte[] buffer, int timeout = 1000 * 5, CancellationToken token = default);
- /// <summary>
- /// 异步发送
- /// </summary>
- /// <param name="byteBlock">数据块载体</param>
- /// <param name="timeout">超时时间</param>
- /// <param name="token">取消令箭</param>
- /// <exception cref="NotConnectedException">客户端没有连接</exception>
- /// <exception cref="OverlengthException">发送数据超长</exception>
- /// <exception cref="Exception">其他异常</exception>
- /// <returns>返回的数据</returns>
- Task<ResponsedData> SendThenResponseAsync(ByteBlock byteBlock, int timeout = 1000 * 5, CancellationToken token = default);
- }
- }
|