fixes in hub.py

broqer/hub.py

@@ -202,7 +202,7 @@ def assign(self, topic_str: str, publisher: Publisher,
             topic._subject = publisher
 
         if len(topic._subscriptions):
-            topic._subject.subscribe(topic)
+            publisher.subscribe(topic)
 
         if meta:
             topic.meta = meta
@@ -212,8 +212,9 @@ def assign(self, topic_str: str, publisher: Publisher,
 
         return topic
 
+
 class SubHub:
-    def __init__(self, hub: Hub, prefix: str):
+    def __init__(self, hub: Hub, prefix: str) -> None:
         self._hub = hub
         assert not prefix.endswith('.'), 'Prefix should not end with \'.\''
         assert prefix, 'Prefix should not be empty'
@@ -226,24 +227,25 @@ def __contains__(self, topic: str) -> bool:
         return self._prefix + topic in self._hub
 
     def __iter__(self):
-        l = len(self._prefix)
-        return (t[l:] for t in self._hub if t.startswith(self._prefix))
+        length = len(self._prefix)
+        return (t[length:] for t in self._hub if t.startswith(self._prefix))
 
     @property
     def topics(self):
-        l = len(self._prefix)
-        topics = ((n[l:], t) for (n, t) in self._hub.topics.items()
+        length = len(self._prefix)
+        topics = ((n[length:], t) for (n, t) in self._hub.topics.items()
                   if n.startswith(self._prefix))
         return MappingProxyType(OrderedDict(topics))
 
     @property
     def unassigned_topics(self):
-        l = len(self._prefix)
-        topics = ((n[l:], t) for (n, t) in self._hub.unassigned_topics.items()
+        length = len(self._prefix)
+        topics = ((n[length:], t) for (n, t)
+                  in self._hub.unassigned_topics.items()
                   if n.startswith(self._prefix))
         return MappingProxyType(OrderedDict(topics))
 
     def assign(self, topic_str: str, publisher: Publisher,
                meta: Optional[dict]=None) -> Topic:
 
-        return self._hub.assign(self._prefix + topic_str, publisher, meta)
+        return self._hub.assign(self._prefix + topic_str, publisher, meta)