1.1 --- a/pprocess.py Sat Sep 15 19:42:24 2007 +0000
1.2 +++ b/pprocess.py Sat Sep 15 23:46:55 2007 +0000
1.3 @@ -609,6 +609,18 @@
1.4 self.results.append(None) # placeholder
1.5 Exchange.start(self, callable, *args, **kw)
1.6
1.7 + def create(self):
1.8 +
1.9 + """
1.10 + Using pprocess.create, create a new process and return the created
1.11 + communications channel to the created process. In the creating process,
1.12 + return None - the channel receiving data from the created process will
1.13 + be automatically managed by this exchange.
1.14 + """
1.15 +
1.16 + self.results.append(None) # placeholder
1.17 + return Exchange.create(self)
1.18 +
1.19 def __call__(self, callable, sequence):
1.20
1.21 "Wrap and invoke 'callable' for each element in the 'sequence'."