fixed links in README to readthedocs.io

README.rst

@@ -50,7 +50,7 @@ Synopsis
 .. _GitHub.com: https://github.com/semiversus/python-broqer
 .. _ReadTheDocs.com: http://python-broqer.readthedocs.io
 .. _ReactiveX: http://reactivex.io/
-.. _Hub: https://github.com/semiversus/python-broqer/blob/master/broqer/hub/hub.py
+.. _Hub: https://python-broqer.readthedocs.io/en/latest/hub.html
 
 Showcase
 ========
@@ -205,34 +205,34 @@ Broqer was inspired by:
 .. _aioreactive: https://github.com/dbrattli/aioreactive
 .. _streamz: https://github.com/mrocklin/streamz
 .. _MQTT: http://mqtt.org/
-.. _Subject: https://github.com/semiversus/python-broqer/blob/master/broqer/subject.py
-.. _Value: https://github.com/semiversus/python-broqer/blob/master/broqer/subject.py
-.. _Publisher: https://github.com/semiversus/python-broqer/blob/master/broqer/publisher.py
-.. _StatefulPublisher: https://github.com/semiversus/python-broqer/blob/master/broqer/publisher.py
-.. _Subscriber: https://github.com/semiversus/python-broqer/blob/master/broqer/subscriber.py
-.. _Accumulate: https://github.com/semiversus/python-broqer/blob/master/broqer/op/accumulate.py
-.. _Cache: https://github.com/semiversus/python-broqer/blob/master/broqer/op/cache.py
-.. _CatchException: https://github.com/semiversus/python-broqer/blob/master/broqer/op/catch_exception.py
-.. _CombineLatest: https://github.com/semiversus/python-broqer/blob/master/broqer/op/combine_latest.py
-.. _Debounce: https://github.com/semiversus/python-broqer/blob/master/broqer/op/debounce.py
-.. _Delay: https://github.com/semiversus/python-broqer/blob/master/broqer/op/delay.py
-.. _Filter: https://github.com/semiversus/python-broqer/blob/master/broqer/op/filter_.py
-.. _FromPolling: https://github.com/semiversus/python-broqer/blob/master/broqer/op/publishers/from_polling.py
-.. _MapAsync: https://github.com/semiversus/python-broqer/blob/master/broqer/op/map_async.py
-.. _MapThreaded: https://github.com/semiversus/python-broqer/blob/master/broqer/op/map_threaded.py
-.. _Map: https://github.com/semiversus/python-broqer/blob/master/broqer/op/map_.py
-.. _Merge: https://github.com/semiversus/python-broqer/blob/master/broqer/op/merge.py
-.. _Partition: https://github.com/semiversus/python-broqer/blob/master/broqer/op/partition.py
-.. _Reduce: https://github.com/semiversus/python-broqer/blob/master/broqer/op/reduce.py
-.. _Replace: https://github.com/semiversus/python-broqer/blob/master/broqer/op/replace.py
-.. _Sample: https://github.com/semiversus/python-broqer/blob/master/broqer/op/sample.py
-.. _Sink: https://github.com/semiversus/python-broqer/blob/master/broqer/op/subscribers/sink.py
-.. _SlidingWindow: https://github.com/semiversus/python-broqer/blob/master/broqer/op/sliding_window.py
-.. _Switch: https://github.com/semiversus/python-broqer/blob/master/broqer/op/switch.py
-.. _Throttle: https://github.com/semiversus/python-broqer/blob/master/broqer/op/throttle.py
-.. _OnEmitFuture: https://github.com/semiversus/python-broqer/blob/master/broqer/op/subscribers/on_emit_future.py
-.. _Trace: https://github.com/semiversus/python-broqer/blob/master/broqer/op/subscribers/trace.py
-.. _hub.utils.TopicMapper: https://github.com/semiversus/python-broqer/blob/master/broqer/hub/utils/topic_mapper.py
+.. _Subject: https://python-broqer.readthedocs.io/en/latest/subjects.html#subject
+.. _Value: https://python-broqer.readthedocs.io/en/latest/subjects.html#value
+.. _Publisher: https://python-broqer.readthedocs.io/en/latest/publishers.html#publisher
+.. _StatefulPublisher: https://python-broqer.readthedocs.io/en/latest/publishers.html#statefulpublisher
+.. _Subscriber: https://python-broqer.readthedocs.io/en/latest/subscribers.html#subscriber
+.. _Accumulate: https://python-broqer.readthedocs.io/en/latest/operators/accumulate.html
+.. _Cache: https://python-broqer.readthedocs.io/en/latest/operators/cache.html
+.. _CatchException: https://python-broqer.readthedocs.io/en/latest/operators/catch_exception.py
+.. _CombineLatest: https://python-broqer.readthedocs.io/en/latest/operators/combine_latest.py
+.. _Debounce: https://python-broqer.readthedocs.io/en/latest/operators/debounce.py
+.. _Delay: https://python-broqer.readthedocs.io/en/latest/operators/delay.py
+.. _Filter: https://python-broqer.readthedocs.io/en/latest/operators/filter_.py
+.. _FromPolling: https://python-broqer.readthedocs.io/en/latest/operators/publishers/from_polling.py
+.. _MapAsync: https://python-broqer.readthedocs.io/en/latest/operators/map_async.py
+.. _MapThreaded: https://python-broqer.readthedocs.io/en/latest/operators/map_threaded.py
+.. _Map: https://python-broqer.readthedocs.io/en/latest/operators/map_.py
+.. _Merge: https://python-broqer.readthedocs.io/en/latest/operators/merge.py
+.. _Partition: https://python-broqer.readthedocs.io/en/latest/operators/partition.py
+.. _Reduce: https://python-broqer.readthedocs.io/en/latest/operators/reduce.py
+.. _Replace: https://python-broqer.readthedocs.io/en/latest/operators/replace.py
+.. _Sample: https://python-broqer.readthedocs.io/en/latest/operators/sample.py
+.. _Sink: https://python-broqer.readthedocs.io/en/latest/operators/subscribers/sink.py
+.. _SlidingWindow: https://python-broqer.readthedocs.io/en/latest/operators/sliding_window.py
+.. _Switch: https://python-broqer.readthedocs.io/en/latest/operators/switch.py
+.. _Throttle: https://python-broqer.readthedocs.io/en/latest/operators/throttle.py
+.. _OnEmitFuture: https://python-broqer.readthedocs.io/en/latest/subscribers.html#trace
+.. _Trace: https://python-broqer.readthedocs.io/en/latest/subscribers.html#trace
+.. _hub.utils.TopicMapper: https://python-broqer.readthedocs.io/en/latest/subscribers.html#trace
 
 .. api
 

docs/subscribers.rst

@@ -1,6 +1,10 @@
 Subscribers
 ===========
 
+Subscriber
+----------
+.. autoclass:: broqer.Subscriber
+
 Sink
 ----
 .. autoclass:: broqer.op.Sink