UnSubscribe unsubscribe a Notifer.
(_ context.Context, req *meta.UnSubscribeRequest)
| 51 | |
| 52 | // UnSubscribe unsubscribe a Notifer. |
| 53 | func (n *Notifer) UnSubscribe(_ context.Context, req *meta.UnSubscribeRequest) (*meta.UnSubscribeResponse, error) { |
| 54 | n.broker.UnSubscribe(req.ID) |
| 55 | return &meta.UnSubscribeResponse{}, nil |
| 56 | } |
| 57 | |
| 58 | // Push push a message to gate. |
| 59 | func (n *Notifer) Push(_ context.Context, req *meta.PushRequest) (*meta.PushResponse, error) { |
nothing calls this directly
no test coverage detected