type nhooyr.io/websocket.Conn

51 uses

	nhooyr.io/websocket (current package)
		accept.go#L82: func Accept(w http.ResponseWriter, r *http.Request, opts *AcceptOptions) (*Conn, error) {
		accept.go#L86: func accept(w http.ResponseWriter, r *http.Request, opts *AcceptOptions) (_ *Conn, err error) {
		close.go#L101: func (c *Conn) Close(code StatusCode, reason string) error {
		close.go#L108: func (c *Conn) CloseNow() (err error) {
		close.go#L120: func (c *Conn) closeHandshake(code StatusCode, reason string) (err error) {
		close.go#L137: func (c *Conn) writeClose(code StatusCode, reason string) error {
		close.go#L172: func (c *Conn) waitCloseHandshake() error {
		close.go#L280: func (c *Conn) setCloseErr(err error) {
		close.go#L286: func (c *Conn) setCloseErrLocked(err error) {
		close.go#L292: func (c *Conn) isClosed() bool {
		conn.go#L45: type Conn struct {
		conn.go#L95: func newConn(cfg connConfig) *Conn {
		conn.go#L96: 	c := &Conn{
		conn.go#L130: 	runtime.SetFinalizer(c, func(c *Conn) {
		conn.go#L145: func (c *Conn) Subprotocol() string {
		conn.go#L149: func (c *Conn) close(err error) {
		conn.go#L177: func (c *Conn) timeoutLoop() {
		conn.go#L203: func (c *Conn) flate() bool {
		conn.go#L214: func (c *Conn) Ping(ctx context.Context) error {
		conn.go#L224: func (c *Conn) ping(ctx context.Context, p string) error {
		conn.go#L255: 	c  *Conn
		conn.go#L259: func newMu(c *Conn) *mu {
		dial.go#L105: func Dial(ctx context.Context, u string, opts *DialOptions) (*Conn, *http.Response, error) {
		dial.go#L109: func dial(ctx context.Context, urls string, opts *DialOptions, rand io.Reader) (_ *Conn, _ *http.Response, err error) {
		netconn.go#L48: func NetConn(ctx context.Context, c *Conn, msgType MessageType) net.Conn {
		netconn.go#L97: 	c       *Conn
		read.go#L36: func (c *Conn) Reader(ctx context.Context) (MessageType, io.Reader, error) {
		read.go#L42: func (c *Conn) Read(ctx context.Context) (MessageType, []byte, error) {
		read.go#L63: func (c *Conn) CloseRead(ctx context.Context) context.Context {
		read.go#L87: func (c *Conn) SetReadLimit(n int64) {
		read.go#L99: func newMsgReader(c *Conn) *msgReader {
		read.go#L161: func (c *Conn) readRSV1Illegal(h header) bool {
		read.go#L173: func (c *Conn) readLoop(ctx context.Context) (header, error) {
		read.go#L210: func (c *Conn) readFrameHeader(ctx context.Context) (header, error) {
		read.go#L239: func (c *Conn) readFramePayload(ctx context.Context, p []byte) (int, error) {
		read.go#L269: func (c *Conn) handleControl(ctx context.Context, h header) (err error) {
		read.go#L329: func (c *Conn) reader(ctx context.Context) (_ MessageType, _ io.Reader, err error) {
		read.go#L361: 	c *Conn
		read.go#L464: 	c     *Conn
		read.go#L470: func newLimitReader(c *Conn, r io.Reader, limit int64) *limitReader {
		write.go#L30: func (c *Conn) Writer(ctx context.Context, typ MessageType) (io.WriteCloser, error) {
		write.go#L44: func (c *Conn) Write(ctx context.Context, typ MessageType, p []byte) error {
		write.go#L53: 	c *Conn
		write.go#L67: func newMsgWriter(c *Conn) *msgWriter {
		write.go#L96: func (c *Conn) writer(ctx context.Context, typ MessageType) (io.WriteCloser, error) {
		write.go#L104: func (c *Conn) write(ctx context.Context, typ MessageType, p []byte) (int, error) {
		write.go#L234: func (c *Conn) writeControl(ctx context.Context, opcode opcode, p []byte) error {
		write.go#L246: func (c *Conn) writeFrame(ctx context.Context, fin bool, flate bool, opcode opcode, p []byte) (_ int, err error) {
		write.go#L338: func (c *Conn) writeFramePayload(p []byte) (n int, err error) {
		write.go#L394: func (c *Conn) writeError(code StatusCode, err error) {

	github.com/gotd/td/internal/wsutil
		conn.go#L11: func NetConn(c *websocket.Conn) net.Conn {