DocumentWriter.cs

using System;
using System.Threading;
using System.Threading.Channels;
using System.Threading.Tasks;
using Couchbase.Lite;

namespace ChannelQueue
{
    class DocumentWriter : IDisposable
    {
        private readonly MutableDocument _document;
        private readonly Thread _currentThread;

        private readonly
            Channel<(string key, string value, TaskCompletionSource<IMutableDictionary> taskCompletionSource)> _channel;


        public DocumentWriter(MutableDocument document)
        {
            _document = document;
            _channel = Channel.CreateUnbounded<(string key, string value, TaskCompletionSource<IMutableDictionary> taskCompletionSource)>();
            _currentThread = new Thread(Start);
            _currentThread.Start();
        }

        private async void Start()
        {
            while (await _channel.Reader.WaitToReadAsync())
            {
                var item = await _channel.Reader.ReadAsync();
                var result = _document.SetString(item.key, item.value);
                item.taskCompletionSource.SetResult(result);

            }

        }

        public async Task<IMutableDictionary> WriteToDocumentAsync(string key, string value)
        {
            var taskCompletionSource = new TaskCompletionSource<IMutableDictionary>();
            await _channel.Writer.WriteAsync((key, value, taskCompletionSource));
            return await taskCompletionSource.Task;
        }


        public void Dispose()
        {
            _channel.Writer.Complete();

        }
    }
}