(addr string, handler Handler)
| 102 | } |
| 103 | |
| 104 | func (srv *Server) Connect(addr string, handler Handler) (*Session, error) { |
| 105 | conn, err := net.DialTimeout("tcp", addr, time.Duration(time.Second*5)) |
| 106 | if err != nil { |
| 107 | return nil, err |
| 108 | } |
| 109 | return srv.newSession(conn, handler), nil |
| 110 | } |
| 111 | |
| 112 | //在ListenAndServe之前调用 |
| 113 | func (srv *Server) SetMaxPacketSize(size uint32) { |
no test coverage detected