File tree Expand file tree Collapse file tree 1 file changed +1
-4
lines changed
include/ydb-cpp-sdk/library/grpc/client Expand file tree Collapse file tree 1 file changed +1
-4
lines changed Original file line number Diff line number Diff line change @@ -1075,7 +1075,7 @@ class TStreamRequestReadWriteProcessor
10751075 Y_ABORT_UNLESS (ReadActive, " Unexpected Read done callback" );
10761076 Y_ABORT_UNLESS (!ReadFinished, " Unexpected ReadFinished flag" );
10771077
1078- if (!ok || Cancelled || WriteFinished ) {
1078+ if (!ok || Cancelled) {
10791079 ReadFinished = true ;
10801080 if (!WriteActive) {
10811081 WriteFinished = true ;
@@ -1124,9 +1124,6 @@ class TStreamRequestReadWriteProcessor
11241124 if (!ok || Cancelled) {
11251125 WriteActive = false ;
11261126 WriteFinished = true ;
1127- if (!ReadActive) {
1128- ReadFinished = true ;
1129- }
11301127 if (ReadFinished) {
11311128 Stream->Finish (&Status, OnFinishedTag.Prepare ());
11321129 }
You can’t perform that action at this time.
0 commit comments