diff options
| author | Roman Smrž <roman.smrz@seznam.cz> | 2024-08-31 22:17:16 +0200 |
|---|---|---|
| committer | Roman Smrž <roman.smrz@seznam.cz> | 2024-11-16 10:12:49 +0100 |
| commit | b3cd90262f521d9c207b395f175cd3b26d2f4363 (patch) | |
| tree | 8755bb1e2f9e4e2654542f30bf2b6fede9b44dca /src/network.h | |
| parent | a689af61eb91dcbc135890276a3c6281166d30f9 (diff) | |
Network streams, accept for data response
Changelog: Implemented streams in network protocol
Diffstat (limited to 'src/network.h')
| -rw-r--r-- | src/network.h | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/src/network.h b/src/network.h index 4c23b47..12013fe 100644 --- a/src/network.h +++ b/src/network.h @@ -54,6 +54,7 @@ struct Server::Peer PartialStorage partStorage; vector<tuple<UUID, shared_ptr<WaitingRef>>> serviceQueue {}; + vector< shared_ptr< NetworkProtocol::InStream >> dataResponseStreams {}; shared_ptr<erebos::Peer::Priv> lpeer = nullptr; @@ -61,6 +62,7 @@ struct Server::Peer void updateChannel(ReplyBuilder &); void finalizeChannel(ReplyBuilder &, unique_ptr<Channel>); void updateService(ReplyBuilder &, vector<tuple<shared_ptr<erebos::Peer::Priv>, Service &, Ref>> & readyServices); + void checkDataResponseStreams( ReplyBuilder & ); }; struct Peer::Priv : enable_shared_from_this<Peer::Priv> |