質問をすることでしか得られない、回答やアドバイスがある。

15分調べてもわからないことは、質問しよう!

ただいまの
回答率

90.54%

  • C#

    7073questions

    C#はマルチパラダイムプログラミング言語の1つで、命令形・宣言型・関数型・ジェネリック型・コンポーネント指向・オブジェクティブ指向のプログラミング開発すべてに対応しています。

  • Visual Studio

    1822questions

    Microsoft Visual StudioはMicrosoftによる統合開発環境(IDE)です。多種多様なプログラミング言語に対応しています。

  • .NET Framework

    455questions

    .NET Framework は、Microsoft Windowsのオペレーティングシステムのために開発されたソフトウェア開発環境/実行環境です。多くのプログラミング言語をサポートしています。

  • ReactiveX

    7questions

  • Rx.NET

    3questions

【C#】【Rx】Observable.FromEventメソッドの引数が何を表現しているのかが分かりません

解決済

回答 1

投稿 編集

  • 評価
  • クリップ 0
  • VIEW 68

galmacher

score 8

Rxの勉強をしており、.NETのイベントハンドラ(今回はMouseMoveイベント)を、
IObservableシーケンスに変換してくれるFromEventメソッドの理解を深めようとしています。
ネットのサンプルコードを見ていると以下のようなコードによく出くわします。

IObservable<MouseEventArgs> mouseMove = Observable.FromEvent<MouseEventHandler, MouseEventArgs>(
        h => (s, e) => h(e),
        h => this.MouseMove += h,
        h => this.MouseMove -= h);


これはFromEventメソッドの中でも下記オーバーロードを利用している認識です。

IObservable<TEventArgs> FromEvent<TEventHandler, TEventArgs>(
   Func<Action<TEventArgs>, TEventHandler> conversion,
   Action<TEventHandler> addHandler,
   Action<TEventHandler> removeHandler)

この3つの引数とサンプルコードの引数がどのように対応しているのかを教えていただきたいです。
現段階では引数1:conversionについて考えて迷路に迷い込んでいる状態です。
仰々しく書くと
『引数convserionに「イベント情報(TEventArgs)を引数として受け取るデリゲート(Action)」を渡してください。戻り値でイベントハンドラ(TEventHandler)を返却します。』
という理解なのですが、それがなぜhだのsだのeだので表現出来ているのかが謎です。
どなたか分かりやすくご説明いただけないでしょうか?

  • 気になる質問をクリップする

    クリップした質問は、後からいつでもマイページで確認できます。

    またクリップした質問に回答があった際、通知やメールを受け取ることができます。

    クリップを取り消します

  • 良い質問の評価を上げる

    以下のような質問は評価を上げましょう

    • 質問内容が明確
    • 自分も答えを知りたい
    • 質問者以外のユーザにも役立つ

    評価が高い質問は、TOPページの「注目」タブのフィードに表示されやすくなります。

    質問の評価を上げたことを取り消します

  • 評価を下げられる数の上限に達しました

    評価を下げることができません

    • 1日5回まで評価を下げられます
    • 1日に1ユーザに対して2回まで評価を下げられます

    質問の評価を下げる

    teratailでは下記のような質問を「具体的に困っていることがない質問」、「サイトポリシーに違反する質問」と定義し、推奨していません。

    • プログラミングに関係のない質問
    • やってほしいことだけを記載した丸投げの質問
    • 問題・課題が含まれていない質問
    • 意図的に内容が抹消された質問
    • 広告と受け取られるような投稿

    評価が下がると、TOPページの「アクティブ」「注目」タブのフィードに表示されにくくなります。

    質問の評価を下げたことを取り消します

    この機能は開放されていません

    評価を下げる条件を満たしてません

    評価を下げる理由を選択してください

    詳細な説明はこちら

    上記に当てはまらず、質問内容が明確になっていない質問には「情報の追加・修正依頼」機能からコメントをしてください。

    質問の評価を下げる機能の利用条件

    この機能を利用するためには、以下の事項を行う必要があります。

回答 1

checkベストアンサー

+2

ラムダ式です。
それがわかれば理解できます。
わからなければ理解できません。

ラムダ式についてはラムダ式っていうのが分かりません で書いたので詳細は省略します。
これでわからなければネット上に情報はたくさんありますので検索してみてください。

追記

ラムダ式を使わず書いてみました。

using System;
using System.Diagnostics;
using System.Reactive.Linq;
using System.Windows.Forms;

namespace WindowsFormsApp1
{
    public partial class Form1 : Form
    {
        public Form1()
        {
            InitializeComponent();
        }

        private void button1_Click(object sender, EventArgs args)
        {
            Observable
                .FromEvent<MouseEventHandler, MouseEventArgs>(
                    //h => (s, e) => h(e),
                    Conversion,

                    //h => this.MouseMove += h,
                    AddHandler,

                    //h => this.MouseMove -= h)
                    RemoveHandler)
                .Subscribe(e =>
                {
                    Debug.WriteLine($"({e.X},{e.Y})");
                });
        }

        private MouseEventHandler Conversion(Action<MouseEventArgs> h)
        {
            void action(object s, MouseEventArgs e)
            {
                h(e);
            }
            return action;
        }

        private void AddHandler(MouseEventHandler h)
        {
            MouseMove += h;
        }

        private void RemoveHandler(MouseEventHandler h)
        {
            MouseMove -= h;
        }
    }
}

FromEvent の引数として、Conversion, AddHandler, RemoveHandler のデリゲートを渡しています。
FromEvent はまず AddHandler を呼び出し、マウスイベントにイベントハンドラを登録します。
そして必要な処理が終われば RemoveHandler を呼び出し、イベントハンドラを削除します。
そして Mouse イベントが起こるたびに Conversion から返された action を呼び出します。
h は FromEvent の登録したデリゲートで、これを呼び出すことにより、以降のオブザーバーに e を渡します。

追記

Observable.FromEvent の中ではだいたいこんなことが行われていると思います。

using System;
using System.Collections.Generic;
using System.Diagnostics;
using System.Reactive.Linq;
using System.Windows.Forms;

namespace WindowsFormsApp1
{
    public partial class Form1 : Form
    {
        public Form1()
        {
            InitializeComponent();
        }

        private void button1_Click(object sender, EventArgs args)
        {
            MyObservable<MouseEventHandler, MouseEventArgs>
                .FromEvent(
                    h => (s, e) => h(e),
                    h => MouseMove += h,
                    h => MouseMove -= h)
                .Subscribe(e =>
                {
                    Debug.WriteLine($"({e.X},{e.Y})");
                });
        }
    }

    class MyObservable<TEventHandler, TEventArgs> : IObservable<TEventArgs>
        where TEventArgs : EventArgs
        where TEventHandler : MulticastDelegate
    {
        protected IList<IObserver<TEventArgs>> Observers { get; } = new List<IObserver<TEventArgs>>();
        protected Action<TEventHandler> AddHandler { get; private set; }
        protected Action<TEventHandler> RemoveHandler { get; private set; }
        protected TEventHandler EventHandler { get; private set; }

        public static IObservable<TEventArgs> FromEvent(
            Func<Action<TEventArgs>, TEventHandler> conversion,
            Action<TEventHandler> addHandler,
            Action<TEventHandler> removeHandler)
        {
            var result = new MyObservable<TEventHandler, TEventArgs>();
            result.AddHandler = addHandler;
            result.RemoveHandler = removeHandler;
            result.EventHandler = conversion(result.Handler);
            result.AddHandler?.Invoke(result.EventHandler);
            return result;
        }

        private void Handler(TEventArgs e)
        {
            foreach (var observer in Observers)
            {
                observer.OnNext(e);
            }
        }

        public IDisposable Subscribe(IObserver<TEventArgs> observer)
        {
            Observers.Add(observer);
            return new Disposable(this, observer);
        }

        protected void RemoveObserver(IObserver<TEventArgs> observer)
        {
            if (Observers.Count == 0) return;
            Observers.Remove(observer);
            if (Observers.Count == 0)
            {
                RemoveHandler?.Invoke(EventHandler);
            }
        }

        class Disposable : IDisposable
        {
            protected MyObservable<TEventHandler, TEventArgs> Owner { get; private set; }
            protected IObserver<TEventArgs> Observer { get; private set; }

            public Disposable(MyObservable<TEventHandler, TEventArgs> owner, IObserver<TEventArgs> observer)
            {
                Owner = owner;
                Observer = observer;
            }

            public void Dispose()
            {
                if (Owner == null) return;
                Owner.RemoveObserver(Observer);
                Owner = null;
            }
        }
    }
}

投稿

編集

  • 回答の評価を上げる

    以下のような回答は評価を上げましょう

    • 正しい回答
    • わかりやすい回答
    • ためになる回答

    評価が高い回答ほどページの上位に表示されます。

  • 回答の評価を下げる

    下記のような回答は推奨されていません。

    • 間違っている回答
    • 質問の回答になっていない投稿
    • スパムや攻撃的な表現を用いた投稿

    評価を下げる際はその理由を明確に伝え、適切な回答に修正してもらいましょう。

  • 2018/10/14 14:20 編集

    ご回答ありがとうございました。
    リンクを貼っていただいている内容はシンプルな例をご記載いただいているので理解できました。
    ただし今回挙げたサンプルコードが何をやっているのかについてはやはり理解できませんでした。

    キャンセル

  • 2018/10/14 16:54

    追記しました。

    キャンセル

  • 2018/10/14 21:35

    ありがとうございます。
    Conversionの部分は、まだ消化するのに時間が要りそうですが、ラムダ式を分解してくださったおかげでずいぶんすっきりしました。
    追記部分も実際に動かしつつ追って動きを確認してみます。

    キャンセル

15分調べてもわからないことは、teratailで質問しよう!

  • ただいまの回答率 90.54%
  • 質問をまとめることで、思考を整理して素早く解決
  • テンプレート機能で、簡単に質問をまとめられる

関連した質問

同じタグがついた質問を見る

  • C#

    7073questions

    C#はマルチパラダイムプログラミング言語の1つで、命令形・宣言型・関数型・ジェネリック型・コンポーネント指向・オブジェクティブ指向のプログラミング開発すべてに対応しています。

  • Visual Studio

    1822questions

    Microsoft Visual StudioはMicrosoftによる統合開発環境(IDE)です。多種多様なプログラミング言語に対応しています。

  • .NET Framework

    455questions

    .NET Framework は、Microsoft Windowsのオペレーティングシステムのために開発されたソフトウェア開発環境/実行環境です。多くのプログラミング言語をサポートしています。

  • ReactiveX

    7questions

  • Rx.NET

    3questions