問題タブ [rx-py]

アンケートを作成できる Discord ボットを作成しています。ユーザーは、ポーリングの長さを引数として指定できます。そのため、5 秒または 10 秒 (またはそれ以上) ごとにメッセージを更新し、投票でユーザーの残り時間を編集したいと考えています。たとえば、3600 秒からのカウントダウンを実装したいのですが、5 秒または 10 秒ごとに、時間が 0 になるまでメッセージを編集する関数を実行します。ボット側のすべてを制御し、多かれ少なかれ方法を知っています。それを実装します。

それで、私が考えたのは、現在の時間が開始時間+ポーリングの期間に等しいときに間隔を空けて停止することです。したがって、rx.interval() を使用してオブザーバブルを作成し、.take_while() のような演算子を使用できます。

これは私のコードです：

しかし、私は得るAttributeError: 'Observable' object has no attribute 'take_while'。

パイプなどに入れる必要があると思います：

しかし、私は得るTypeError: 'bool' object is not callable

take_while はどのように使用できますか? ありがとうございました！

on_next次のように、Pythonrxサブスクリプション内で非同期関数を呼び出す必要があります。

しかし、非同期エラーが発生します:

asyncio.get_event_loop().run_until_complete(...)私はすでにメインループを実行していて、新しいループを開始したくないし、ネストされたループも使用したくないので、本当に使いたくありません。

それについて検索したところ、lambda関数を async にすることはできないことがわかりました。ライブラリon_nextを使用してラムダ関数を使用せずに値を取得する方法が本当にわからないため、ここで問題があると思います。rx

async-rxライブラリについても検索しましたが、これは実行できる唯一の異なることのように見えますが、await subscribe(...)それは私が望むものではありません。のようなものが欲しいsubscribe(on_next=await...)。

それは可能ですか？私のバックグラウンドから、内部で関数javascriptを開始するのは簡単なので、私にとって可能なタスクのように見えます。誰かがそれに対する解決策を見つけてくれることを願っています。asyncsubscribe

どうもありがとう！

これがRxPYで再現しようとしているRxJSコードです。

そして、これは私が同等だったものですが、そうではありません

誰かが私がここで欠けているものを理解するのを手伝ってくれますか?

辞書のリストがあり、このリストに適用して結果を取得したい関数があります。

RxPYを使用してこの結果を取得できますか? ご協力ありがとうございました。