File tree Expand file tree Collapse file tree 2 files changed +11
-4
lines changed
Expand file tree Collapse file tree 2 files changed +11
-4
lines changed Original file line number Diff line number Diff line change 1+ # Unreleased
2+ - [ changed] Internal change to stream implementation, to prepare for handshake. (#13792 )
3+
14# 11.3.0
25- [ changed] Improve efficiency of memory persistence when processing a large number of writes. (#13572 )
36
Original file line number Diff line number Diff line change @@ -108,22 +108,26 @@ class TestStream : public Stream {
108108 observed_states_.push_back (" NotifyStreamOpen" );
109109 }
110110
111- util::Status NotifyFirstStreamResponse (const grpc::ByteBuffer& message) override {
111+ util::Status NotifyFirstStreamResponse (
112+ const grpc::ByteBuffer& message) override {
112113 std::string str = ByteBufferToString (message);
113114 if (str.empty ()) {
114115 observed_states_.push_back (" NotifyFirstStreamResponse" );
115116 } else {
116- observed_states_.push_back (StringFormat (" NotifyFirstStreamResponse(%s)" , str));
117+ observed_states_.push_back (
118+ StringFormat (" NotifyFirstStreamResponse(%s)" , str));
117119 }
118120 return ResolveStreamResponse ();
119121 }
120122
121- util::Status NotifyNextStreamResponse (const grpc::ByteBuffer& message) override {
123+ util::Status NotifyNextStreamResponse (
124+ const grpc::ByteBuffer& message) override {
122125 std::string str = ByteBufferToString (message);
123126 if (str.empty ()) {
124127 observed_states_.push_back (" NotifyNextStreamResponse" );
125128 } else {
126- observed_states_.push_back (StringFormat (" NotifyNextStreamResponse(%s)" , str));
129+ observed_states_.push_back (
130+ StringFormat (" NotifyNextStreamResponse(%s)" , str));
127131 }
128132 return ResolveStreamResponse ();
129133 }
You can’t perform that action at this time.
0 commit comments