()
| 735 | } |
| 736 | |
| 737 | func (handler *RpcResponseHandler) close() { |
| 738 | cancelFn := handler.contextCancelFn.Load() |
| 739 | if cancelFn != nil && *cancelFn != nil { |
| 740 | (*cancelFn)() |
| 741 | handler.contextCancelFn.Store(nil) |
| 742 | } |
| 743 | handler.done.Store(true) |
| 744 | } |
| 745 | |
| 746 | // if async, caller must call finalize |
| 747 | func (handler *RpcResponseHandler) Finalize() { |
no outgoing calls
no test coverage detected