Searched refs:receiving_stream (Results 1 – 1 of 1) sorted by relevance
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 …]