1
2
3
4
5
6
7
8
9
10
11
12
13
14using System;
using System.Threading;
using System.Threading.Tasks;

namespace Xtremegaida.DataStructures;

public interface IDataQueueWriter
{
	bool IsWriteClosed { get; }
	long TotalBytesWritten { get; }
	ValueTask WriteByteAsync(byte data, CancellationToken cancellationToken = default);
	ValueTask WriteAsync(ReadOnlyMemory<byte> buffer, CancellationToken cancellationToken = default);
	void CloseWrite();
}