tesses50/tessesframework
1
0
Fork 0
mirror of https://git.tesses.org/tesses50/tessesframework.git synced 2026-10-01 17:14:13 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add server sent events, change vfs structure, dark mode error pages and dark mode anonydrop

Browse Source
This commit is contained in:
tesses50
2026-04-30 07:04:45 -05:00
parent c55f0c0f4f
commit 86b062771a
13 changed files with 84 additions and 132 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/Streams/Stream.cpp
+7 -9
View File
@@ -108,36 +108,34 @@ namespace Tesses::Framework::Streams {
void Stream::CopyToLimit(std::shared_ptr<Stream> strm,uint64_t len, size_t buffSize)
{
size_t read;
uint8_t* buffer = new uint8_t[buffSize];
std::vector<uint8_t> buffer(buffSize);
uint64_t offset = 0;
do {
if(offset >= len) break;
read = (size_t)std::min(len-offset,(uint64_t)buffSize);
read = (size_t)std::min(len-offset,(uint64_t)buffer.size());
read = this->Read(buffer,read);
strm->WriteBlock(buffer, read);
read = this->Read(buffer.data(),read);
strm->WriteBlock(buffer.data(), read);
offset += read;
} while(read > 0 && !strm->EndOfStream());
strm->Flush();
delete[] buffer;
}
void Stream::CopyTo(std::shared_ptr<Stream> strm, size_t buffSize)
{
size_t read;
uint8_t* buffer = new uint8_t[buffSize];
std::vector<uint8_t> buffer(buffSize);
do {
read = this->Read(buffer,buffSize);
strm->WriteBlock(buffer, read);
read = this->Read(buffer.data(),buffer.size());
strm->WriteBlock(buffer.data(), read);
} while(read > 0 && !strm->EndOfStream());
strm->Flush();
delete[] buffer;
}
Stream::~Stream()