Part of twisted.flow.controller View Source View In Hierarchy
wraps up a Stage with a Deferred interface
In this version, the results of the Stage are used to construct a list of results and then sent to deferred. Further, in this version Cooperate is implemented via reactor's callLater.
For example:from twisted.internet import reactor from twisted.flow import flow def res(x): print x d = flow.Deferred([1,2,3]) d.addCallback(res) reactor.iterate()
Split Table into Classes Show Methods in One Table
| Line # | Kind | Name | Docs |
|---|---|---|---|
| 67 | Method | __init__ | Undocumented |
| 73 | Method | results | Undocumented |
| 76 | Method | _execute | Undocumented |
Inherited from Deferred:
| Line # | Kind | Name | Docs |
|---|---|---|---|
| 172 | Method | addCallbacks | Add a pair of callbacks (success and error) to this Deferred. |
| 189 | Method | addCallback | Convenience method for adding just a callback. |
| 197 | Method | addErrback | Convenience method for adding just an errback. |
| 206 | Method | addBoth | Convenience method for adding a single callable as both a callback |
| 216 | Method | chainDeferred | Chain another Deferred to this Deferred. |
| 233 | Method | callback | Run all success callbacks that have been added to this Deferred. |
| 246 | Method | errback | Run all error callbacks that have been added to this Deferred. |
| 272 | Method | pause | Stop processing on a Deferred until unpause()
is called.
|
| 278 | Method | unpause | Process all callbacks made since pause()
was called.
|
| 355 | Method | setTimeout | Set a timeout function to be triggered if I am not called. |
| 380 | Method | __str__ | Undocumented |
| 287 | Method | _continue | Undocumented |
| 291 | Method | _startRunCallbacks | Undocumented |
| 314 | Method | _runCallbacks | Undocumented |
| Line # | Kind | Name | Docs |
|---|---|---|---|
| 67 | Method | __init__ | Undocumented |
| 380 | Method | __str__ | Undocumented |
| 206 | Method | addBoth | Convenience method for adding a single callable as both a callback |
| 189 | Method | addCallback | Convenience method for adding just a callback. |
| 172 | Method | addCallbacks | Add a pair of callbacks (success and error) to this Deferred. |
| 197 | Method | addErrback | Convenience method for adding just an errback. |
| 233 | Method | callback | Run all success callbacks that have been added to this Deferred. |
| 216 | Method | chainDeferred | Chain another Deferred to this Deferred. |
| 246 | Method | errback | Run all error callbacks that have been added to this Deferred. |
| 272 | Method | pause | Stop processing on a Deferred until unpause()
is called.
|
| 73 | Method | results | Undocumented |
| 355 | Method | setTimeout | Set a timeout function to be triggered if I am not called. |
| 278 | Method | unpause | Process all callbacks made since pause()
was called.
|
| 287 | Method | _continue | Undocumented |
| 76 | Method | _execute | Undocumented |
| 314 | Method | _runCallbacks | Undocumented |
| 291 | Method | _startRunCallbacks | Undocumented |