変更歩留まりのからの戻り値

Question

ですが、私はこれらのパーサーを持っているとしましょう：

parsers = { 
    ".foo": parse_foo, 
    ".bar", parse_bar 
} 

parse_fooとparse_barは行ずつをもたらす両方の発電機です。私は、単一のディスパッチ関数を作成したい場合は、私はこれだろう。

def parse(ext): 
    yield from parsers[ext]() 

を構文からの収量は、発電機を上下に簡単にトンネル情報に私を可能にします。

降伏結果を変更している間にトンネリングを維持する方法はありますか？
トンネリングを壊しながら、そうは簡単です：

def parse(ext): 
    for result in parsers[ext](): 
     # Add the extension to the result 
     result.ext = ext 
     yield result 

しかし、私はすべての方法パーサーに.send()か.throw()を使用することはできませんこの方法。

私が考えている唯一の方法は、について同じことをしながら、try: ... except Exception: ...のような醜い何かを行い、例外を渡すことです。それは醜い、厄介でバグの多い傾向があります。

Answer 1

残念ながらを内蔵していません。クラスを使用して自分で実装することもできますが、cotoolzというパッケージは、まったく同じ機能を実装するmap()を実装しています。

map関数は組み込みのmap()よりも4倍遅いですが、ジェネレータプロトコルを認識していて、Pythonの同様の実装（C言語で記述され、C99コンパイラが必要です）より高速です。

自分のページからの例：

>>> def my_coroutine(): 
...  yield (yield (yield 1)) 
>>> from cotoolz import comap 
>>> cm = comap(lambda a: a + 1, my_coroutine()) 
>>> next(cm) 
2 
>>> cm.send(2) 
3 
>>> cm.send(3) 
4 
>>> cm.send(4) 
Traceback (most recent call last): 
    ... 
StopIteration 

Answer 2

はparse_fooとparse_bar拡張機能を追加しておいてください。

def parse_foo(ext): 
    # Existing code 
    ... 
    # Add an extension to the item(s) 
    item.ext = ext 

def parse(ext): 
    yield from parsers[ext](ext) 

それとも、各機能でそれをハードコード：

def parse_foo(): 
    # Existing code 
    ... 
    # Add an extension to the item(s) 
    item.ext = ".foo" 

Answer 3

はほかtry ... yield ... exceptこれを行う別の方法があります：新しいジェネレータを実装することによって。このクラスを使用すると、すべての入力と、あなたの根本的な発電機の出力を変換することができます。

identity = lambda x: x 
class map_generator: 
    def __init__(self, generator, outfn = identity, 
     infn = identity, throwfn = identity): 
    self.generator = generator 
    self.outfn = outfn 
    self.infn = infn 
    self.throwfn = throwfn 
    self.first = True 
    def __iter__(self): 
    return self 
    def __next__(self): 
    return self.send(None) 
    def _transform(self, value): 
    if self.first: 
     self.first = False 
     return value 
    else: 
     return self.infn(value) 
    def send(self, value): 
    return self.outfn(self.generator.send(self._transform(value))) 
    def throw(self, value): 
    return self.outfn(self.generator.throw(self.throwfn(value))) 
    def next(self): # for python2 support 
    return self.__next__() 

使用法：

def foo(): 
    for i in "123": 
    print("sent to foo: ", (yield i)) 

def bar(): 
    dupe = lambda x:2*x 
    tripe = lambda x:3*x 
    yield from map_generator(foo(), dupe, tripe) 

i = bar() 
print("received from bar: ", i.send(None)) 
print("received from bar: ", i.send("B")) 
print("received from bar: ", i.send("C")) 

... 

received from bar: 11 
sent to foo: BBB 
received from bar: 22 
sent to foo: CCC 
received from bar: 33 

EDIT：あなたはcollections.Iteratorを継承する場合がありますが、それはでは必要ありませんですこのユースケース。