follow up

This commit is contained in:
Alexander Kozachenko 2023-12-02 17:44:58 +03:00
parent a90ac7e17d
commit 478fff51c2

View file

@ -19,12 +19,8 @@ public class RegularSubscriptionTests
string[] expected = [
"introduced an ERROR",
"got a CRITICAL message"
];
];
// var isSubscriptionSupportsPipeline = typeof(PipelineSubscritpion) || subscription.CanDoNext
// source -> RegularSubscription -> DataSubscriber
// TODO: make a fluent provider here.
var subscriber = new DataSubscriber<string>();
var subscription = new RegularSubscription<string>(subscriber, predicate);