22325004088

Committed 23 Feb 2026 09:11PM UTC coverage: 32.847% (-0.2%) from 33.028%

Build # 22325004088

Build Type

push

github

Committed by

Lakritzator

Commit Message

Merge branch 'master' of https://github.com/dapplo/Dapplo.Windows

Coverage Stats

619 of 2002 branches covered (30.92%)

Branch coverage included in aggregate %.

1702 of 5064 relevant lines covered (33.61%)

29.45 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/src/Dapplo.Windows.Input/RawInputMonitor.cs

﻿// Copyright (c) Dapplo and contributors. All rights reserved.
// Licensed under the MIT license. See LICENSE file in the project root for full license information.


#if !NETSTANDARD2_0
using Dapplo.Windows.Input.Enums;
using Dapplo.Windows.Input.Structs;
using Dapplo.Windows.Messages;
using Dapplo.Windows.Messages.Enumerations;
using System;
using System.Reactive.Disposables;
using System.Reactive.Linq;
using System.Runtime.InteropServices;

namespace Dapplo.Windows.Input;

/// <summary>
/// Reactive access to RawInput
/// </summary>
public static class RawInputMonitor
{
    private static IObservable<RawInputEventArgs> _rawInputObservable;

    /// <summary>
    /// Gets the shared observable for Raw Input.
    /// Multiple subscribers will share the same underlying hook, and the hook 
    /// is automatically disposed when the subscriber count reaches zero.
    /// </summary>
    public static IObservable<RawInputEventArgs> Listen(params RawInputDevices[] devices)
    {
        if (_rawInputObservable != null)
        {
            RawInputApi.RegisterRawInput(SharedMessageWindow.Handle, RawInputDeviceFlags.InputSink | RawInputDeviceFlags.DeviceNotify, devices);
            return _rawInputObservable;
        }

        _rawInputObservable = Observable.Create<RawInputEventArgs>(observer =>
        {
            // Subscribe to the SharedMessageWindow for handling the WM_INPUT
            var messageSubscription = SharedMessageWindow.Messages
                .Where(windowsMessage => windowsMessage.Msg == WindowsMessages.WM_INPUT) // filter for raw input
                .Subscribe(windowsMessage =>
                {
                    windowsMessage.Handled = true;
                    int outSize;
                    int size = Marshal.SizeOf<RawInput>();

                    outSize = RawInputApi.GetRawInputData(windowsMessage.LParam, RawInputDataCommands.Input, out var rawInput, ref size, Marshal.SizeOf<RawInputHeader>());
                    if (outSize != -1)
                    {
                        observer.OnNext(new RawInputEventArgs
                        {
                            IsForeground = (int)windowsMessage.WParam == 0,
                            RawInput = rawInput
                        });
                    }
                });

            RawInputApi.RegisterRawInput(SharedMessageWindow.Handle, RawInputDeviceFlags.InputSink | RawInputDeviceFlags.DeviceNotify, devices);

            // Return the disposal logic
            return Disposable.Create(() =>
            {
                // Unregister raw input devices from the OS here if necessary
                // UnregisterRawInputDevices(...);
                _rawInputObservable = null; // Clear the cached observable so it can be recreated if Listen() is called again.
                // Dispose the SharedMessageWindow subscription
                messageSubscription.Dispose();
            });
        })
        // This is the magic part:
        // .Publish() multicasts the observable to all subscribers.
        // .RefCount() keeps track of subscribers and automatically disposes 
        // the inner subscription when the count reaches 0.
        .Publish()
        .RefCount();
        return _rawInputObservable;
    }
}
#endif

1	// Copyright (c) Dapplo and contributors. All rights reserved.
2	// Licensed under the MIT license. See LICENSE file in the project root for full license information.
3
4
5	#if !NETSTANDARD2_0
6	using Dapplo.Windows.Input.Enums;
7	using Dapplo.Windows.Input.Structs;
8	using Dapplo.Windows.Messages;
9	using Dapplo.Windows.Messages.Enumerations;
10	using System;
11	using System.Reactive.Disposables;
12	using System.Reactive.Linq;
13	using System.Runtime.InteropServices;
14
15	namespace Dapplo.Windows.Input;
16
17	/// <summary>
18	/// Reactive access to RawInput
19	/// </summary>
20	public static class RawInputMonitor
21	{
22	private static IObservable<RawInputEventArgs> _rawInputObservable;
23
24	/// <summary>
25	/// Gets the shared observable for Raw Input.
26	/// Multiple subscribers will share the same underlying hook, and the hook
27	/// is automatically disposed when the subscriber count reaches zero.
28	/// </summary>
29	public static IObservable<RawInputEventArgs> Listen(params RawInputDevices[] devices)
30	{
31	if (_rawInputObservable != null)	×
32	{
33	RawInputApi.RegisterRawInput(SharedMessageWindow.Handle, RawInputDeviceFlags.InputSink \| RawInputDeviceFlags.DeviceNotify, devices);	×
34	return _rawInputObservable;	×
35	}
36
37	_rawInputObservable = Observable.Create<RawInputEventArgs>(observer =>	×
38	{	×
39	// Subscribe to the SharedMessageWindow for handling the WM_INPUT	×
40	var messageSubscription = SharedMessageWindow.Messages	×
41	.Where(windowsMessage => windowsMessage.Msg == WindowsMessages.WM_INPUT) // filter for raw input	×
42	.Subscribe(windowsMessage =>	×
43	{	×
44	windowsMessage.Handled = true;	×
45	int outSize;	×
46	int size = Marshal.SizeOf<RawInput>();	×
47		×
48	outSize = RawInputApi.GetRawInputData(windowsMessage.LParam, RawInputDataCommands.Input, out var rawInput, ref size, Marshal.SizeOf<RawInputHeader>());	×
49	if (outSize != -1)	×
50	{	×
51	observer.OnNext(new RawInputEventArgs	×
52	{	×
53	IsForeground = (int)windowsMessage.WParam == 0,	×
54	RawInput = rawInput	×
55	});	×
56	}	×
57	});	×
58		×
59	RawInputApi.RegisterRawInput(SharedMessageWindow.Handle, RawInputDeviceFlags.InputSink \| RawInputDeviceFlags.DeviceNotify, devices);	×
60		×
61	// Return the disposal logic	×
62	return Disposable.Create(() =>	×
63	{	×
64	// Unregister raw input devices from the OS here if necessary	×
65	// UnregisterRawInputDevices(...);	×
66	_rawInputObservable = null; // Clear the cached observable so it can be recreated if Listen() is called again.	×
67	// Dispose the SharedMessageWindow subscription	×
68	messageSubscription.Dispose();	×
69	});	×
70	})	×
71	// This is the magic part:	×
72	// .Publish() multicasts the observable to all subscribers.	×
73	// .RefCount() keeps track of subscribers and automatically disposes	×
74	// the inner subscription when the count reaches 0.	×
75	.Publish()	×
76	.RefCount();	×
77	return _rawInputObservable;	×
78	}
79	}
80	#endif

dapplo / Dapplo.Windows / 22325004088

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous