python - Reactive 拡張機能の create で repeat(n) が機能しない理由

Question

from rx import Observable, Observer
from __future__ import print_function
import random

def create_observable(observer):
    while True:
        observer.on_next(random.randint(1,100))    

Observable.create(create_observable).take_while(lambda x: x>50).repeat(6).subscribe(print)

与える

74 78 94 59 79 76

シーケンス、各数字が6回繰り返されることを期待していますが

そのため、create メソッドで作成されたオブザーバブルに対して「繰り返し」が機能することはありません。