Commit5798948

committed

fixup! ws_js: Update to match new close code

1 parenta9e9d67 commit5798948Copy full SHA for 5798948

File tree

-4

lines changed

-4

lines changed

Lines changed: 3 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -64,9 +64,10 @@ func (c *Conn) Read(ctx context.Context) (MessageType, []byte, error) {`
`64`	`64`	`// This function is idempotent.`
`65`	`65`	`func (c*Conn)CloseRead(ctx context.Context) context.Context {`
`66`	`66`	`c.closeReadMu.Lock()`
`67`		`-ifc.closeReadCtx!=nil {`
	`67`	`+ctx2:=c.closeReadCtx`
	`68`	`+ifctx2!=nil {`
`68`	`69`	`c.closeReadMu.Unlock()`
`69`		`-returnc.closeReadCtx`
	`70`	`+returnctx2`
`70`	`71`	`}`
`71`	`72`	`ctx,cancel:=context.WithCancel(ctx)`
`72`	`73`	`c.closeReadCtx=ctx`

Lines changed: 3 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -392,9 +392,10 @@ func (w *writer) Close() error {`
`392`	`392`	`// CloseRead implements *Conn.CloseRead for wasm.`
`393`	`393`	`func (c*Conn)CloseRead(ctx context.Context) context.Context {`
`394`	`394`	`c.closeReadMu.Lock()`
`395`		`-ifc.closeReadCtx!=nil {`
	`395`	`+ctx2:=c.closeReadCtx`
	`396`	`+ifctx2!=nil {`
`396`	`397`	`c.closeReadMu.Unlock()`
`397`		`-returnc.closeReadCtx`
	`398`	`+returnctx2`
`398`	`399`	`}`
`399`	`400`	`ctx,cancel:=context.WithCancel(ctx)`
`400`	`401`	`c.closeReadCtx=ctx`

Comments

(0)