(srv *Server, transport string, fl *flakeyListener)
| 494 | } |
| 495 | |
| 496 | func httpTestClient(srv *Server, transport string, fl *flakeyListener) (*Client, *httptest.Server) { |
| 497 | // Create the HTTP server. |
| 498 | var hs *httptest.Server |
| 499 | switch transport { |
| 500 | case "ws": |
| 501 | hs = httptest.NewUnstartedServer(srv.WebsocketHandler([]string{"*"})) |
| 502 | case "http": |
| 503 | hs = httptest.NewUnstartedServer(srv) |
| 504 | default: |
| 505 | panic("unknown HTTP transport: " + transport) |
| 506 | } |
| 507 | // Wrap the listener if required. |
| 508 | if fl != nil { |
| 509 | fl.Listener = hs.Listener |
| 510 | hs.Listener = fl |
| 511 | } |
| 512 | // Connect the client. |
| 513 | hs.Start() |
| 514 | client, err := Dial(transport + "://" + hs.Listener.Addr().String()) |
| 515 | if err != nil { |
| 516 | panic(err) |
| 517 | } |
| 518 | return client, hs |
| 519 | } |
| 520 | |
| 521 | func ipcTestClient(srv *Server, fl *flakeyListener) (*Client, net.Listener) { |
| 522 | // Listen on a random endpoint. |
no test coverage detected