blob: 7cdc1268d448cf7138b3dd87d25e25bc23fceb54 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
|
#include "cru/common/io/AutoReadStream.h"
#include <vector>
#include "cru/common/io/Stream.h"
namespace cru::io {
AutoReadStream::AutoReadStream(Stream* stream, bool auto_delete,
const AutoReadStreamOptions& options) {
background_thread_ = std::thread(&AutoReadStream::BackgroundThreadRun, this);
}
bool AutoReadStream::CanSeek() { return false; }
Index AutoReadStream::Seek(Index offset, SeekOrigin origin) {
throw StreamOperationNotSupportedException(
u"AutoReadStream does not support seek.");
}
bool AutoReadStream::CanWrite() { return stream_->CanWrite(); }
Index AutoReadStream::Write(const std::byte* buffer, Index offset, Index size) {
return stream_->Write(buffer, offset, size);
}
void AutoReadStream::Flush() { stream_->Flush(); }
void AutoReadStream::BackgroundThreadRun() {
std::unique_lock<std::mutex> lock(buffer_mutex_);
std::vector<std::byte>* buffer = nullptr;
if (!buffer_list_.empty()) {
}
stream_->Read();
}
}
} // namespace cru::io
|
