Skip to content

Commit 2389eb1

Browse files
committed
Fix CI
1 parent ce14550 commit 2389eb1

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

bench_test.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -99,6 +99,6 @@ func benchConn(b *testing.B, stream bool) {
9999
}
100100

101101
func BenchmarkConn(b *testing.B) {
102-
benchConn(b, true)
103102
benchConn(b, false)
103+
benchConn(b, true)
104104
}

websocket.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -460,7 +460,7 @@ type messageWriter struct {
460460

461461
// Write writes the given bytes to the WebSocket connection.
462462
func (w messageWriter) Write(p []byte) (int, error) {
463-
n, err := w.Write(p)
463+
n, err := w.write(p)
464464
if err != nil {
465465
return n, xerrors.Errorf("failed to write: %w", err)
466466
}
@@ -522,14 +522,14 @@ func (w messageWriter) close() error {
522522
// You can only read a single message at a time so do not call this method
523523
// concurrently.
524524
func (c *Conn) Reader(ctx context.Context) (MessageType, io.Reader, error) {
525-
typ, r, err := c.Reader(ctx)
525+
typ, r, err := c.reader(ctx)
526526
if err != nil {
527527
return 0, nil, xerrors.Errorf("failed to get reader: %w", err)
528528
}
529529
return typ, r, nil
530530
}
531531

532-
func (c *Conn) reader(ctx context.Context) (MessageType, io.Reader, error) {
532+
func (c *Conn) reader(ctx context.Context) (MessageType, io.Reader, error) {
533533
for !atomic.CompareAndSwapInt64(&c.activeReader, 0, 1) {
534534
select {
535535
case <-c.closed:

0 commit comments

Comments
 (0)