using System;
using System.Threading.Tasks;

namespace FinlyticBot.Services.Mqtt;

public interface IBotRpcClient
{
    Task<TResponse?> SendRpcRequestAsync<TResponse, TRequest>(
        string channel,
        TRequest requestData,
        TimeSpan? timeout = null)
        where TResponse : class
        where TRequest : class;

    Task PublishAsync<T>(string topic, T data, bool retain = false);
}