using System;

namespace ScreenConnect;

public abstract class CaptureStreamManager<TStreamState> : IDisposable
{
	private Type boundaryMessageType;

	protected Proc<TStreamState> StreamStateDisposer { get; set; }

	protected CaptureStreamManager(Proc<TStreamState> streamStateDisposer)
	{
		StreamStateDisposer = streamStateDisposer;
	}

	public bool IsBoundaryMessage(CaptureStreamMessage message)
	{
		Type type = message.GetType();
		if ((object)boundaryMessageType == null && type.GetCustomAttribute<CaptureStreamStateBoundaryMessageAttribute>() != null)
		{
			boundaryMessageType = type;
		}
		return (object)type == boundaryMessageType;
	}

	public bool AreFromSameStream(CaptureStreamMessage x, CaptureStreamMessage y)
	{
		return x.StreamID == y.StreamID;
	}

	public abstract TStreamState GetStreamState(CaptureStreamMessage message);

	public abstract void Dispose();
}