# HG changeset patch
# User paulb
# Date 1127927316 0
# Node ID cc1da13abc2b1161479c1553e46c0dddbfe4cc6b
# Parent  a915bbb6cb54396e12019da1fdebcec3a49a7c1e
[project @ 2005-09-28 17:08:34 by paulb]
Changed the Exchange class's active method to return a list of channels.

diff -r a915bbb6cb54 -r cc1da13abc2b parallel.py
--- a/parallel.py	Wed Sep 28 16:24:06 2005 +0000
+++ b/parallel.py	Wed Sep 28 17:08:36 2005 +0000
@@ -57,6 +57,12 @@
 
 exchange = Exchange(channels)
 
+To test whether an exchange is active - that is, whether it is actually
+monitoring any channels - we can use the active method which returns all
+channels being monitored by the exchange:
+
+channels = exchange.active()
+
 We may then check the exchange to see whether any data is ready to be received;
 for example:
 
@@ -89,6 +95,8 @@
 http://twistedmatrix.com/pipermail/twisted-python/2005-February/009666.html
 """
 
+__version__ = "0.1"
+
 import os
 import sys
 import select
@@ -179,9 +187,9 @@
 
     def active(self):
 
-        "Return the number of active channels."
+        "Return a list of active channels."
 
-        return len(self.readables.keys())
+        return self.readables.values()
 
     def ready(self, timeout=None):
 
diff -r a915bbb6cb54 -r cc1da13abc2b tests/start_indexer.py
--- a/tests/start_indexer.py	Wed Sep 28 16:24:06 2005 +0000
+++ b/tests/start_indexer.py	Wed Sep 28 17:08:36 2005 +0000
@@ -23,7 +23,7 @@
 
         exchange = Exchange(channels)
         while exchange.active():
-            print "Waiting for %d channels..." % exchange.active()
+            print "Waiting for %d channels..." % len(exchange.active())
             for channel in exchange.ready():
                 entry = channel.receive()
                 master_index.add_entry(entry)