コード:

auto doubleClickStream = clickStream
	.time_interval()		// 前回からの経過時間を送信
	.filter([](auto v) {	// 500ms より短いイベントのみ処理
	using namespace std::chrono;
	return (duration_cast<milliseconds>(v).count() < 500);
});

auto send_mousePos = doubleClickStream
	.map([](auto) {
	// とりあえず bool型を送信
	return true;
});

コード:

// プログラムの先頭に， #define NOMINMAXを書いておくこと。<windows.h>のminマクロのために，minの呼び出しでエラーになる。
    auto doubleClickStream = clickStream
        .filter([](int) {
        static std::chrono::steady_clock::time_point last = std::chrono::steady_clock::time_point::min(); // 初期の「前回の時刻」はminを使う。
        auto now = std::chrono::steady_clock::now();
        auto duration = now - last;
        auto count = std::chrono::duration_cast<std::chrono::milliseconds>(duration).count(); // 現在時刻と前回の時刻の差をミリ秒で取得
        if (0 < count && count < 500) { // 500ms未満はダブルクリック
            last = std::chrono::steady_clock::time_point::min(); // ダブルクリックを検知したので，前回の時刻は「押していない」状態
            return true;
        }
        else {
            last = now; // ダブルクリックでなかったので，前回の時刻は「今回の時刻」
            return false;
        }
    });

    auto send_mousePos = doubleClickStream
        .map([](int) {
        // とりあえず bool型を送信
        return true;
    });

コード:

/*
*	・「Reactive Extensions」の調査
*		- RxCppによるダブルクリックの実装
//*/

#include "DxLib.h"      // DxLib

// nuget rxcpp 3.0.1
// This software includes the work that is distributed in the Apache License 2.0
#include <rx.hpp>
namespace Rx
{
	using namespace rxcpp;
	using namespace rxcpp::subjects;
	using namespace rxcpp::operators;
	using namespace rxcpp::util;
}

// DXライブラリ簡易ラップクラス
template<int windowWidth_ = 640, int windowHeight_ = 480, int colorBitDepth_ = 32>
struct DxLibApp final
{
	DxLibApp(const wchar_t* pWindowText = L"無題")
	{
		DxLib::SetWindowText(pWindowText);
		SetGraphMode(windowWidth_, windowHeight_, colorBitDepth_);
		ChangeWindowMode(TRUE);
		if (DxLib_Init() == -1) {
			throw;
		}
		SetDrawScreen(DX_SCREEN_BACK);
	}

	~DxLibApp() {
		DxLib_End();
	}

	static bool Update() {
		return (ScreenFlip() == 0 && ProcessMessage() == 0 && ClearDrawScreen() == 0);
	}
};

// 簡易入力クラス
struct Input final
{
	Input()
		: mouse_()
	{}

	~Input() {}

	inline int Update() {
		mouse_.Update();
		return 0;
	}

	struct Mouse final
	{
		Mouse()
			: keyBuffer_(0)
			, backKeyBuffer_(0)
		{}

		inline int Update() {
			backKeyBuffer_ = keyBuffer_;
			keyBuffer_ = GetMouseInput();
			return 0;
		}

		inline bool IsPress(const int keyCode) const {
			return ((keyBuffer_ & keyCode) != 0);
		}

		inline bool IsDown(const int keyCode) const {
			return ((keyBuffer_ & keyCode) && !(backKeyBuffer_ & keyCode));
		}

		inline bool IsUp(const int keyCode) const {
			return (!(keyBuffer_ & keyCode) && (backKeyBuffer_ & keyCode));
		}

	private:
		int  keyBuffer_;
		int  backKeyBuffer_;
	};

	Mouse		mouse_;
};

static DxLibApp<> app(L"Rxによるイベント処理");
static Input input;

// エントリーポイント
int WINAPI WinMain(HINSTANCE, HINSTANCE, LPSTR, int)
{
	// Updateイベント (<int>はダミー)
	Rx::subject<int> update_subject;
	auto update_subscriber = update_subject.get_subscriber();
	auto update_observable = update_subject.get_observable();

	auto clickStream = update_observable
		.filter([](int) {return input.mouse_.IsDown(MOUSE_INPUT_LEFT);});

	// ここのイベント通知の定義に、
	// ダブルクリックらしく制限時間を設けたい
	auto doubleClickStream = clickStream.buffer(2);
	auto send_mousePos = doubleClickStream
		.map([](std::vector<int>) {
			// とりあえず bool型を送信
			return true;
	});
	auto subscription = send_mousePos.subscribe([](bool) {
		printfDx(L"2クリック\n");
	});
	
	// メインループ
	while (DxLibApp<>::Update() && input.Update() == 0)
	{
		// Update通知
		update_subscriber.on_next(1);
	}

	// 解除
	subscription.unsubscribe();

	return 0;
}