using System.Threading.Tasks; using System.IO; namespace MQTTnet.Core.Channel { public interface IMqttChannel { Stream SendStream { get; } Stream ReceiveStream { get; } Task ConnectAsync(); Task DisconnectAsync(); } }