int SFtp::Read(SFtpHandle handle, Event<const void*, int>&& consumer, int size) // Data read engine.
{
        int sz = min(size, ssh->chunksize) 
 	Buffer<char> buffer(sz);
	int rc = libssh2_sftp_read(HANDLE(handle), buffer, sz);
	if(!WouldBlock(rc) && rc < 0)
		SetError(rc);
	if(rc > 0) {
		consumer(buffer, rc);
		sftp->done += rc;
                if(WhenProgress(sftp->done, size))
			SetError(-1, "Read aborted.");
		ssh->start_time = msecs();
	}
	return rc;
}

int SFtp::Get(SFtpHandle* handle, void* buffer, int size)
{
	
        Clear();
 	Cmd(SFTP_GET, [=]() mutable {
		int rc = Read(
			handle,
			[=](const void* p, int sz)
			{
					if(!buffer)
						SetError(-1, "Invalid pointer to read buffer");
				memcpy((char*)(buffer + sftp->done), (char*)p, sz);
			},
			size
		);
		if(rc >= 0)
			sftp->value = sftp->done;
		return rc == 0 || sftp->done == size;
	});
	return sftp->done;
}