(msg ziface.IMessage)
| 176 | } |
| 177 | |
| 178 | func (d *DemoPacket) Pack(msg ziface.IMessage) ([]byte, error) { |
| 179 | time.Sleep(time.Second * 1) |
| 180 | return d.DataPack.Pack(msg) |
| 181 | } |
| 182 | |
| 183 | func (br *CloseConnectionBeforeSendMsgRouter) Handle(req ziface.IRequest) { |
| 184 | connection := req.GetConnection() |