Changes between Version 1 and Version 2 of DeferredGenerator

Timestamp:

08/31/2006 01:02:25 PM (7 years ago)

Author:

yang

Comment:

minor fixes in code snippet

DeferredGenerator

@@ -10 +10 @@
 #!python
 
-    from twisted.internet import defer
-    
-    # The reactor is running and we are going to obtain a Deferred "d"
-
-    def getSomeDeferred():
-         """Some function that returns a Deferred."""
-         d = defer.Deferred()
-         reactor.callLater(2, d.callback, 'A string that yells "foo!"')
-         return d
-    
-    def anotherDeferred(needle, haystack):
-         """Some other function that returns a Deferred."""
-         d = defer.Deferred()
-         reactor.callLater(2, d.callback, haystack.find(needle))
-         return d
-    
-    @defer.deferredGenerator
-    def find(needle):
-         """A Deferred generator function"""
-         print "I am going to find %s in a haystack." % needle
-         # After yielding waitForDeferred, our generator
-         # will be put on hold for a while.
-         wfd = defer.waitForDeferred(getSomeDeferred())
-         yield wfd
-         # The reactor will call .next(), and we resume here.
-         haystack = wfd.getResult()
-         print "I got my haystack back from a deferred."
-         # We're going to wait for another deferred result.
-         wfd = defer.waitForDeferred(anotherDeferred(needle, haystack))
-         yield wfd
-         # When we get our next result, the procedure resumes here.
-         print "I found %s at character %d" % (repr(needle), d.getResult())
-
-    # We call the deferred generator like any other function and immediately
-    # get a Deferred that fires when the generator is done.
-
-    d = find('foo!')
+from twisted.internet import defer, reactor
+
+# The reactor is running and we are going to obtain a Deferred "d"
+
+def getSomeDeferred():
+    """Some function that returns a Deferred."""
+    d = defer.Deferred()
+    reactor.callLater(1, d.callback, 'A string that yells "foo!"')
+    return d
+
+def anotherDeferred(needle, haystack):
+    """Some other function that returns a Deferred."""
+    d = defer.Deferred()
+    reactor.callLater(1, d.callback, haystack.find(needle))
+    return d
+
+@defer.deferredGenerator
+def find(needle):
+    """A Deferred generator function"""
+    print "I am going to find %s in a haystack." % needle
+    # After yielding waitForDeferred, our generator
+    # will be put on hold for a while.
+    wfd = defer.waitForDeferred(getSomeDeferred())
+    yield wfd
+    # The reactor will call .next(), and we resume here.
+    haystack = wfd.getResult()
+    print "I got my haystack back from a deferred."
+    # We're going to wait for another deferred result.
+    wfd = defer.waitForDeferred(anotherDeferred(needle, haystack))
+    yield wfd
+    # When we get our next result, the procedure resumes here.
+    print "I found %s at character %d" % (repr(needle), wfd.getResult())
+    reactor.stop()
+
+# We call the deferred generator like any other function and immediately
+# get a Deferred that fires when the generator is done.
+
+d = find('foo!')
+reactor.run()
 }}}