Class Callback
Instruction
--+
|
Stage
--+
|
Callback
- Known Subclasses:
-
_Protocol
Converts a single-thread push interface into a pull interface.
Once this stage is constructed, its result, errback, and
finish member variables may be called by a producer. The
results of which can be obtained by yielding the Callback and
then calling next(). For example:
source = flow.Callback()
reactor.callLater(0, lambda: source.result("one"))
reactor.callLater(.5, lambda: source.result("two"))
reactor.callLater(1, lambda: source.finish())
printFlow(source)
Method Summary |
|
__init__(self,
*trap)
|
|
__call__ (self,
result)
called by the producer to indicate a successful result |
|
__iter__(self)
(inherited from Stage )
|
|
errback (self,
fail)
called by the producer in case of Failure |
|
finish (self)
called by producer to indicate successful stream completion |
|
next (self)
return current result (inherited from Stage )
|
|
result (self,
result)
called by the producer to indicate a successful result |
__call__(self,
result)
(Call operator)
called by the producer to indicate a successful result
-
|
errback(self,
fail)
called by the producer in case of Failure
-
|
finish(self)
called by producer to indicate successful stream completion
-
|
result(self,
result)
called by the producer to indicate a successful result
-
|