elsa-core/src/modules/Elsa.Workflows.Runtime/Services/BookmarkQueueSignaler.cs

namespace Elsa.Workflows.Runtime;

public class BookmarkQueueSignaler : IBookmarkQueueSignaler
{
    private TaskCompletionSource? _tsc;

    public Task AwaitAsync()
    {
        _tsc ??= new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
        return _tsc.Task.ContinueWith(_ => _tsc = null);
    }

    public void Trigger()
    {
        _tsc?.TrySetResult();
    }
}