Searched refs:receiving_stream (Results 1 – 2 of 2) sorted by relevance
186 grpc_core::OrphanablePtr<grpc_core::ByteStream> receiving_stream; member505 c->receiving_stream.reset(); in destroy_call()1205 size_t remaining = call->receiving_stream->length() - in continue_receiving_slices()1209 call->receiving_stream.reset(); in continue_receiving_slices()1213 if (call->receiving_stream->Next(remaining, &call->receiving_slice_ready)) { in continue_receiving_slices()1214 error = call->receiving_stream->Pull(&call->receiving_slice); in continue_receiving_slices()1219 call->receiving_stream.reset(); in continue_receiving_slices()1239 error = call->receiving_stream->Pull(&slice); in receiving_slice_ready()1254 call->receiving_stream.reset(); in receiving_slice_ready()1267 if (call->receiving_stream == nullptr) { in process_data_after_md()[all …]
225 grpc_core::OrphanablePtr<grpc_core::ByteStream> receiving_stream; member545 c->receiving_stream.reset(); in destroy_call()1260 size_t remaining = call->receiving_stream->length() - in continue_receiving_slices()1264 call->receiving_stream.reset(); in continue_receiving_slices()1268 if (call->receiving_stream->Next(remaining, &call->receiving_slice_ready)) { in continue_receiving_slices()1269 error = call->receiving_stream->Pull(&call->receiving_slice); in continue_receiving_slices()1274 call->receiving_stream.reset(); in continue_receiving_slices()1295 error = call->receiving_stream->Pull(&slice); in receiving_slice_ready()1310 call->receiving_stream.reset(); in receiving_slice_ready()1323 if (call->receiving_stream == nullptr) { in process_data_after_md()[all …]