We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 08c4bda commit 0d2bf39Copy full SHA for 0d2bf39
lib/service/registry.dart
@@ -126,7 +126,9 @@ class RegistryService {
126
} else {
127
sendRegistryRequest(pk);
128
subs.add(key);
129
- streams[key] = StreamController<SignedRegistryEntry>.broadcast();
+ if (!streams.containsKey(key)) {
130
+ streams[key] = StreamController<SignedRegistryEntry>.broadcast();
131
+ }
132
if (getFromDB(pk) == null) {
133
node.logger.verbose('[registry] get (clean) $key');
134
for (int i = 0; i < 200; i++) {
0 commit comments