24940020806

Committed 25 Apr 2026 08:30PM UTC coverage: 28.251% (-1.5%) from 29.75%

Build # 24940020806

Build Type

push

coveralls.net

Committed by

DemoBytom

Commit Message

Remove old `StaThreadService` and related codebase

Superseeded by `WindowsMessagePump`

Coverage Stats

1208 of 4276 relevant lines covered (28.25%)

0.32 hits per line

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

0.0

/src/Demo.Engine.Core/Features/StaThread/StaThreadWriter.cs

// Copyright © Michał Dembski and contributors.
// Distributed under MIT license. See LICENSE file in the root for more information.

using System.Threading.Channels;
using Demo.Engine.Core.Interfaces.Rendering;
using Demo.Engine.Core.ValueObjects;

namespace Demo.Engine.Core.Features.StaThread;

internal sealed class StaThreadWriter(
    ChannelWriter<StaThreadRequests> channelWriter)
    : IStaThreadWriter,
      IDisposable
{
    private readonly ChannelWriter<StaThreadRequests> _channelWriter = channelWriter;
    private bool _disposedValue;

    public async Task<RenderingSurfaceId> CreateSurface(
        IRenderingEngine renderingEngine,
        CancellationToken cancellationToken = default)
    {
        var createSurfaceRequest = StaThreadRequests.CreateSurface(renderingEngine);
        await _channelWriter.WriteAsync(
                createSurfaceRequest,
                cancellationToken);

        return await createSurfaceRequest.Invoked;
    }

    private void Dispose(bool disposing)
    {
        if (!_disposedValue)
        {
            if (disposing)
            {
                _channelWriter.Complete();
            }

            _disposedValue = true;
        }
    }

    public void Dispose()
    {
        // Do not change this code. Put cleanup code in 'Dispose(bool disposing)' method
        Dispose(disposing: true);
        GC.SuppressFinalize(this);
    }
}

1	// Copyright © Michał Dembski and contributors.
2	// Distributed under MIT license. See LICENSE file in the root for more information.
3
4	using System.Threading.Channels;
5	using Demo.Engine.Core.Interfaces.Rendering;
6	using Demo.Engine.Core.ValueObjects;
7
8	namespace Demo.Engine.Core.Features.StaThread;
9
10	internal sealed class StaThreadWriter(	×
11	ChannelWriter<StaThreadRequests> channelWriter)	×
12	: IStaThreadWriter,
13	IDisposable
14	{
15	private readonly ChannelWriter<StaThreadRequests> _channelWriter = channelWriter;	×
16	private bool _disposedValue;
17
18	public async Task<RenderingSurfaceId> CreateSurface(
19	IRenderingEngine renderingEngine,
20	CancellationToken cancellationToken = default)
21	{
22	var createSurfaceRequest = StaThreadRequests.CreateSurface(renderingEngine);	×
23	await _channelWriter.WriteAsync(	×
24	createSurfaceRequest,	×
25	cancellationToken);	×
26
27	return await createSurfaceRequest.Invoked;	×
28	}	×
29
30	private void Dispose(bool disposing)
31	{
32	if (!_disposedValue)	×
33	{
34	if (disposing)	×
35	{
36	_channelWriter.Complete();	×
37	}
38
39	_disposedValue = true;	×
40	}
41	}	×
42
43	public void Dispose()
44	{
45	// Do not change this code. Put cleanup code in 'Dispose(bool disposing)' method
46	Dispose(disposing: true);	×
47	GC.SuppressFinalize(this);	×
48	}	×
49	}

DemoBytom / DemoEngine / 24940020806

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