TAbLZMACompressionStream

type TAbLZMACompressionStream = class(TStream)

protected

  FOutputStream: TStream;

  FBufferCriticalSection: TRTLCriticalSection;

  FPendingWorkSemaphore: THandle;

  FLZMAEncHandle: CLzmaEncHandle;

  FCompressionThread: TAbLZMACompressionThread;

  FCompressionErrorCode: Integer;

  FPIntermediateCompressionBuffer: PAbQueuedBuffer;

  FIntermediateCompressionBufferAvailableBytes: Integer;

  FQueuedData: TAbQueuedBuffer;

  FCurrentBufferBytesSubmitted: Integer;

  FOutputStreamHeaderSizeFieldPosition: Int64;

  FTotalBytesWritten: Int64;

  procedure WakeCompressionThread;

public

  constructor Create();

  destructor Destroy; override;

  function Read(); override;

  function Write(); override;

  function Seek();

  procedure NoMoreDataToCompress;

  function WaitForCompressionToFinish;

  function IsBusy;

  property ErrorCode: Integer; [r]

end;

TAbLZMACompressionStream

TObject