| package websocket | |
| import ( | |
| "net" | |
| "time" | |
| "veyron.io/veyron/veyron2/ipc/stream" | |
| ) | |
| func wsListener(protocol, address string) (net.Listener, error) { | |
| ln, err := net.Listen(protocol, address) | |
| if err != nil { | |
| return nil, err | |
| } | |
| return NewListener(ln) | |
| } | |
| func wsDialer(protocol, address string, timeout time.Duration) (net.Conn, error) { | |
| // TODO(cnicolaou): implement timeout support. | |
| return Dial(address) | |
| } | |
| func init() { | |
| for _, p := range []string{"ws", "ws4", "ws6"} { | |
| stream.RegisterProtocol(p, wsDialer, wsListener) | |
| } | |
| } |