将Packet写入队列
发布事件publishEvent()
从队列取出Packet
packet为空,且重试次数大于30
push()| ▼ getStub()
ServerPushRequestStreamObserver.java
调用方法
Java服务端
放入模型
CascadedCaller.java
OnNext()
DataTransferPipedClient.java
非空
重试次数+1
DataTransferServiceImpl.java
Push()
stub.push()
client.push()
Java客户端
判断Packet非空和尝试次数
onApplicationEvent|▼cascadedCaller.push
OnComplete()
PipHandleNotificationEventListener.java
返回响应
Python调用方