17 lines
409 B
C#
17 lines
409 B
C#
using System;
|
|
using System.Threading.Tasks;
|
|
|
|
namespace FinlyticEngine.Services.Mqtt;
|
|
|
|
public interface IEngineRpcClient
|
|
{
|
|
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);
|
|
}
|