refactor: streamline Read and Close methods in buffer.go for improved clarity and efficiency
This commit is contained in:
@@ -110,7 +110,7 @@ func (r *RawChannelReader) Read(p []byte) (n int, err error) {
|
|||||||
if err == io.EOF && !r.eof {
|
if err == io.EOF && !r.eof {
|
||||||
err = nil
|
err = nil
|
||||||
}
|
}
|
||||||
return
|
return n, err
|
||||||
}
|
}
|
||||||
|
|
||||||
func (r *RawChannelReader) HandleMessage(msg channel.MessageBase) bool { // #nosec G115
|
func (r *RawChannelReader) HandleMessage(msg channel.MessageBase) bool { // #nosec G115
|
||||||
@@ -201,10 +201,7 @@ func (b *Buffer) Read(p []byte) (n int, err error) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (b *Buffer) Close() error {
|
func (b *Buffer) Close() error {
|
||||||
if err := b.ReadWriter.Writer.Flush(); err != nil {
|
return b.ReadWriter.Writer.Flush()
|
||||||
return err
|
|
||||||
}
|
|
||||||
return nil
|
|
||||||
}
|
}
|
||||||
|
|
||||||
func CreateReader(streamID int, ch *channel.Channel, readyCallback func(int)) *bufio.Reader {
|
func CreateReader(streamID int, ch *channel.Channel, readyCallback func(int)) *bufio.Reader {
|
||||||
|
|||||||
Reference in New Issue
Block a user