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