FileStream write

[pbreda]

Boas, tenho um problema com o filestream tento usar este código

PackageManager.ClientPack.Add((int)Packages.UPClientPackages.RECEIVE_UPDATE, (data) =>
{
	byte[] inData = PackageManager.ReadBytesPackage(data.Length - 4, data);

	fs.Write(inData, 0, inData.Length);
    Thread.Sleep(10);
    bytesRecived += inData.Length;
    fs.Flush();
    OnUpdateDownload?.Invoke(bytesRecived, fileInfo.FileLenght);
});

e a app pára a escrita a não ser que use o Thread.sleep(10) não estou a perceber pq...alguém me consegue explicar?

[M6]

Não vejo muito sentido em parares a thread (em especial se for a principal) quando recebeste dados e estás a meio da escrita.

[pbreda]

senão parar o thread o ficheiro fica interrompido....pelo que me a percebi não termina a escrita a tempo do próximo bloco ser escrito...não consigo encontrar outra solução pra alem dessa...já tentei com BeginWrite e BeginRead mas não sei pq, não funciona corretamente. Também tentei com async e o await e nada...fica na mesma. 

 

ClientServer.Start(serverAddr, port, () =>
            {
                PackageManager.ClientPack.Add((int)Packages.UPClientPackages.CONNECTED_OK, (data) =>
                {
                    OnClientConnected?.Invoke();

                    ClientServer.SendData(PackageManager.WriteStringPackage((int)Packages.UPServerPackages.CHECK_UPDATE, JsonSerializer.SerializeToString(Converters.GetApplicationInfoFromAssembly(app)))); 
                });

                PackageManager.ClientPack.Add((int)Packages.UPClientPackages.UPDATE_NEED, (data) =>
                {
                    OnCheckForUpdateComplete?.Invoke(Convert.ToBoolean(PackageManager.ReadShortPackage(data)));
                });

                PackageManager.ClientPack.Add((int)Packages.UPClientPackages.RECEIVE_FILE_INFO, (data) =>
                {
                    fileInfo = JsonDeserializer.DeserializeFromString(PackageManager.ReadStringPackage(data), typeof(FileInfoModel));

                    fs = File.Open(fileInfo.FileName, FileMode.OpenOrCreate);

                    ClientServer.SendData(PackageManager.WriteShortPackage((int)Packages.UPServerPackages.DOWNLOAD_UPDATE, 1));
                });

                PackageManager.ClientPack.Add((int)Packages.UPClientPackages.RECEIVE_UPDATE, (data) =>
                {
                    byte[] inData = PackageManager.ReadBytesPackage(data.Length - 4, data);

                    fs.Write(inData, 0, inData.Length);
                    Thread.Sleep(10);
                    bytesRecived += inData.Length;
                    fs.Flush();
                    OnUpdateDownload?.Invoke(bytesRecived, fileInfo.FileLenght);
                });

            });

Este código é da função completa....talvez dê mais sentido ao problema em questão.

[M6]

Tipicamente esse tipo de funcionalidade costuma ser lançada numa thread própria para não bloquear a principal.
Podes ir recebendo a informação e colecionando a mesma e mandares escrever o ficheiro apenas quando já tens a informação toda completa do teu lado.

[pbreda]

humm....consegues me dar um exemplo ou um tutorial pra ter uma ideia de como o fazer?