Better NT subscription handling

This commit is contained in:
Tyler Wilcox 2025-06-19 10:02:10 -04:00
parent e38494104b
commit b35ca5460d
1 changed files with 7 additions and 5 deletions

View File

@ -4,15 +4,17 @@ import "package:nt4/nt4.dart";
NT4Client ntClient = NT4Client(serverBaseAddress: '10.5.78.2', onConnect: () { print("NT4 Connected"); }, onDisconnect: () { print("NT4 Disconnected"); }); NT4Client ntClient = NT4Client(serverBaseAddress: '10.5.78.2', onConnect: () { print("NT4 Connected"); }, onDisconnect: () { print("NT4 Disconnected"); });
List<NT4Subscription> nt4Subscriptions = []; Map<String, NT4Subscription> nt4Subscriptions = {};
NT4Subscription subscribe(String topic){ NT4Subscription subscribe(String topic){
NT4Subscription subscrip = ntClient.subscribe(topic, NT4SubscriptionOptions()); if (!nt4Subscriptions.containsKey(topic))
{
NT4Subscription subscrip = ntClient.subscribe(topic, NT4SubscriptionOptions());
nt4Subscriptions[topic] = subscrip;
}
nt4Subscriptions.add(subscrip); return nt4Subscriptions[topic]!;
return subscrip;
} }
List<NT4Topic> nt4Topics = []; List<NT4Topic> nt4Topics = [];