Avalonia/src/Avalonia.FreeDesktop/DBusHelper.cs

using System;
using System.Threading;
using Avalonia.Threading;
using Tmds.DBus;

namespace Avalonia.FreeDesktop
{
    public class DBusHelper
    {
        /// <summary>
        /// This class uses synchronous execution at DBus connection establishment stage
        /// then switches to using AvaloniaSynchronizationContext
        /// </summary>
        class DBusSyncContext : SynchronizationContext
        {
            private SynchronizationContext _ctx;
            private object _lock = new object();

            public override void Post(SendOrPostCallback d, object state)
            {
                lock (_lock)
                {
                    if (_ctx != null)
                        _ctx?.Post(d, state);
                    else
                        lock (_lock)
                            d(state);
                }
            }

            public override void Send(SendOrPostCallback d, object state)
            {
                lock (_lock)
                {
                    if (_ctx != null)
                        _ctx?.Send(d, state);
                    else

                        d(state);
                }
            }

            public void Initialized()
            {
                lock (_lock)
                    _ctx = new AvaloniaSynchronizationContext(null);
            }
        }
        public static Connection Connection { get; private set; }

        public static Exception TryInitialize(string dbusAddress = null)
        {
            var oldContext = SynchronizationContext.Current;
            try
            {

                var dbusContext = new DBusSyncContext();
                SynchronizationContext.SetSynchronizationContext(dbusContext);
                var conn = new Connection(new ClientConnectionOptions(dbusAddress ?? Address.Session)
                {
                    AutoConnect = false,
                    SynchronizationContext = dbusContext
                });
                // Connect synchronously
                conn.ConnectAsync().Wait();

                // Initialize a brand new sync-context
                dbusContext.Initialized();
                Connection = conn;
            }
            catch (Exception e)
            {
                return e;
            }
            finally
            {
                SynchronizationContext.SetSynchronizationContext(oldContext);
            }
            return null;
        }
    }
}