Skip to content

Commit c0cba16

Browse files
committed
lint & fmt
1 parent 9e285c7 commit c0cba16

File tree

2 files changed

+2
-4
lines changed

2 files changed

+2
-4
lines changed

agent/immortalstreams/stream.go

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -451,7 +451,6 @@ func (s *Stream) startCopyingLocked() {
451451

452452
// Use a buffer for copying
453453
n, err := s.pipe.Read(buf)
454-
455454
if err != nil {
456455
// Check for fatal errors that should terminate the goroutine
457456
if xerrors.Is(err, io.ErrClosedPipe) {

agent/immortalstreams/stream_test.go

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -495,7 +495,7 @@ func TestStream_ReconnectionScenarios(t *testing.T) {
495495
// Use context-aware copying to prevent hangs
496496
go func() {
497497
<-serverCtx.Done()
498-
c.Close()
498+
_ = c.Close()
499499
}()
500500
_, _ = io.Copy(c, c)
501501
}(conn)
@@ -707,7 +707,6 @@ func TestStream_ReconnectionScenarios(t *testing.T) {
707707
}
708708
}
709709
})
710-
711710
}
712711

713712
func TestStream_SequenceNumberReconnection_WithSequenceNumbers(t *testing.T) {
@@ -874,7 +873,7 @@ func TestStream_SequenceNumberReconnection_WithDataLoss(t *testing.T) {
874873
// Use context-aware copying to prevent hangs
875874
go func() {
876875
<-serverCtx.Done()
877-
c.Close()
876+
_ = c.Close()
878877
}()
879878
_, _ = io.Copy(c, c)
880879
}(conn)

0 commit comments

Comments
 (0)