Ton

1
/*
2
    This file is part of TON Blockchain Library.
3

4
    TON Blockchain Library is free software: you can redistribute it and/or modify
5
    it under the terms of the GNU Lesser General Public License as published by
6
    the Free Software Foundation, either version 2 of the License, or
7
    (at your option) any later version.
8

9
    TON Blockchain Library is distributed in the hope that it will be useful,
10
    but WITHOUT ANY WARRANTY; without even the implied warranty of
11
    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
12
    GNU Lesser General Public License for more details.
13

14
    You should have received a copy of the GNU Lesser General Public License
15
    along with TON Blockchain Library.  If not, see <http://www.gnu.org/licenses/>.
16

17
    Copyright 2017-2020 Telegram Systems LLP
18
*/
19
#include "StreamInterface.h"
20
namespace td {
21
StreamReader::StreamReader(std::shared_ptr<StreamReaderInterface> self) : self(std::move(self)) {
22
}
23
size_t StreamReader::reader_size() {
24
  return self->reader_size();
25
}
26
Slice StreamReader::prepare_read() {
27
  return self->prepare_read();
28
}
29
Span<IoSlice> StreamReader::prepare_readv() {
30
  return self->prepare_readv();
31
}
32
void StreamReader::confirm_read(size_t size) {
33
  return self->confirm_read(size);
34
}
35

36
void StreamReader::close_reader(Status error) {
37
  return self->close_reader(std::move(error));
38
}
39
bool StreamReader::is_writer_closed() const {
40
  return self->is_writer_closed();
41
}
42
Status &StreamReader::writer_status() {
43
  return self->writer_status();
44
}
45

46
StreamWriter::StreamWriter(std::shared_ptr<StreamWriterInterface> self) : self(std::move(self)) {
47
}
48
size_t StreamWriter::writer_size() {
49
  return self->writer_size();
50
}
51
MutableSlice StreamWriter::prepare_write() {
52
  return self->prepare_write();
53
}
54
MutableSlice StreamWriter::prepare_write_at_least(size_t size) {
55
  return self->prepare_write_at_least(size);
56
}
57
void StreamWriter::confirm_write(size_t size) {
58
  return self->confirm_write(size);
59
}
60
void StreamWriter::append(Slice data) {
61
  return self->append(data);
62
}
63
void StreamWriter::append(BufferSlice data) {
64
  return self->append(std::move(data));
65
}
66
void StreamWriter::append(std::string data) {
67
  return self->append(std::move(data));
68
}
69

70
void StreamWriter::close_writer(Status error) {
71
  return self->close_writer(std::move(error));
72
}
73
bool StreamWriter::is_reader_closed() const {
74
  return self->is_reader_closed();
75
}
76
Status &StreamWriter::reader_status() {
77
  return self->reader_status();
78
}
79
}  // namespace td
80