diff options
| author | Roman Smrž <roman.smrz@seznam.cz> | 2024-08-31 22:17:16 +0200 |
|---|---|---|
| committer | Roman Smrž <roman.smrz@seznam.cz> | 2024-09-29 10:02:17 +0200 |
| commit | 81895699131121a1dab67ce026dcf8490c4de9e0 (patch) | |
| tree | 5f373addbf9355a73d22c0b0ee840afe100eff93 /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> |