Skip to content

Commit db2b09f

Browse files
committed
refactor: remove unused syncReader type and associated methods
1 parent 69f7a88 commit db2b09f

File tree

1 file changed

+0
-35
lines changed

1 file changed

+0
-35
lines changed

flight/doexchange.go

Lines changed: 0 additions & 35 deletions
Original file line numberDiff line numberDiff line change
@@ -576,38 +576,3 @@ func (s *Server) handleTableFunction(ctx context.Context, stream flight.FlightSe
576576

577577
return nil
578578
}
579-
580-
type syncReader struct {
581-
array.RecordReader
582-
writer *SchemaWriter
583-
err error
584-
isInit bool
585-
closed bool
586-
}
587-
588-
func (sr *syncReader) Next() bool {
589-
if sr.isInit {
590-
if err := sr.writer.WriteFinished(); err != nil {
591-
sr.err = err
592-
return false
593-
}
594-
}
595-
if !sr.isInit {
596-
sr.isInit = true
597-
}
598-
if !sr.RecordReader.Next() {
599-
return false
600-
}
601-
return true
602-
}
603-
604-
func (sr *syncReader) Err() error {
605-
if sr.err != nil {
606-
return sr.err
607-
}
608-
return sr.RecordReader.Err()
609-
}
610-
611-
func (sr *syncReader) Release() {
612-
sr.writer.WriteFinished()
613-
}

0 commit comments

Comments
 (0)