19 lines
471 B
C#
19 lines
471 B
C#
using System;
|
|
using System.Threading.Tasks;
|
|
using ShardingCore.Sharding.Enumerators;
|
|
using ShardingCore.Sharding.Enumerators.StreamMergeSync;
|
|
|
|
namespace ShardingCore.Sharding.Abstractions
|
|
{
|
|
/*
|
|
* @Author: xjm
|
|
* @Description:
|
|
* @Date: Saturday, 14 August 2021 22:05:40
|
|
* @Email: 326308290@qq.com
|
|
*/
|
|
public interface IStreamMergeEngine<T>
|
|
{
|
|
Task<IStreamMergeAsyncEnumerator<T>> GetAsyncEnumerator();
|
|
IStreamMergeEnumerator<T> GetEnumerator();
|
|
}
|
|
} |