mirror of
https://github.com/rdkit/rdkit.git
synced 2026-06-05 22:04:27 +08:00
79 lines
1.6 KiB
Python
Executable File
79 lines
1.6 KiB
Python
Executable File
# $Id$
|
|
#
|
|
# Copyright (C) 2003 Rational Discovery LLC
|
|
# All Rights Reserved
|
|
#
|
|
import sys
|
|
|
|
from VLib.Node import VLibNode
|
|
|
|
class OutputNode(VLibNode):
|
|
""" base class for nodes which dump output
|
|
|
|
Assumptions:
|
|
|
|
- destination supports a write() method
|
|
|
|
- strFunc, if provided, returns a string representation of
|
|
the input
|
|
|
|
- inputs (parents) can be stepped through in lockstep
|
|
|
|
|
|
Usage Example:
|
|
>>> from VLib.Supply import SupplyNode
|
|
>>> supplier = SupplyNode(contents=[1,2,3])
|
|
>>> import StringIO
|
|
>>> io = StringIO.StringIO()
|
|
>>> node = OutputNode(dest=io,strFunc=lambda x:'%s '%(str(x)))
|
|
>>> node.AddParent(supplier)
|
|
>>> node.next()
|
|
1
|
|
>>> io.getvalue()
|
|
'1 '
|
|
>>> node.next()
|
|
2
|
|
>>> io.getvalue()
|
|
'1 2 '
|
|
|
|
"""
|
|
def __init__(self,dest=None,strFunc=None,**kwargs):
|
|
VLibNode.__init__(self,**kwargs)
|
|
self._dest = dest
|
|
self._func=strFunc
|
|
def next(self):
|
|
parents = self.GetParents()
|
|
args = []
|
|
for parent in parents:
|
|
try:
|
|
args.append(parent.next())
|
|
except StopIteration:
|
|
raise StopIteration
|
|
if len(args)>1:
|
|
args = tuple(args)
|
|
else:
|
|
args = args[0]
|
|
if self._func is not None:
|
|
outp = self._func(args)
|
|
else:
|
|
outp = str(args)
|
|
if self._dest:
|
|
self._dest.write(outp)
|
|
return args
|
|
|
|
#------------------------------------
|
|
#
|
|
# doctest boilerplate
|
|
#
|
|
def _test():
|
|
import doctest,sys
|
|
return doctest.testmod(sys.modules["__main__"])
|
|
|
|
if __name__ == '__main__':
|
|
import sys
|
|
failed,tried = _test()
|
|
sys.exit(failed)
|
|
|
|
|
|
|