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