How does TaskManager announce JobManager about available ResultPartitions?

[Fork Joseph]

Hi,

According to description in
https://cwiki.apache.org/confluence/display/FLINK/Data+exchange+between+tasks,
TaskManager announces (tells) JobManager about available
ResultSubpartitions  (RSs) to let another TM to initiate the transfer.
However, I can’t find where in the codebase TM actually announces JM about
RSs for streaming (Pipelined) mode.

Thanks!
Joseph