diff --git a/lib/service/registry.dart b/lib/service/registry.dart
index a5d3cf1..fab6a1e 100644
--- a/lib/service/registry.dart
+++ b/lib/service/registry.dart
@@ -126,7 +126,9 @@ class RegistryService {
     } else {
       sendRegistryRequest(pk);
       subs.add(key);
-      streams[key] = StreamController<SignedRegistryEntry>.broadcast();
+      if (!streams.containsKey(key)) {
+        streams[key] = StreamController<SignedRegistryEntry>.broadcast();
+      }
       if (getFromDB(pk) == null) {
         node.logger.verbose('[registry] get (clean) $key');
         for (int i = 0; i < 200; i++) {