Sign in
apache
/
pulsar-dotpulsar
/
8b8e32620189311906d63726e7da2bb71f0fdad7
/
.
/
src
/
DotPulsar
/
Internal
/
Abstractions
/
IConsumerStreamFactory.cs
blob: b8767ff6f3d5a2b02ab985dbe64ae68beedc448f [
file
] [
log
] [
blame
]
using
System
.
Threading
;
using
System
.
Threading
.
Tasks
;
namespace
DotPulsar
.
Internal
.
Abstractions
{
public
interface
IConsumerStreamFactory
{
Task
<
IConsumerStream
>
CreateStream
(
IConsumerProxy
proxy
,
CancellationToken
cancellationToken
=
default
);
}
}