🦥 zerocopy: remove CloseRead

Author: database64128

direct/stream.go

@@ -59,11 +59,6 @@ func (rw *DirectStreamReadWriter) CloseWrite() error {
 	return rw.rw.CloseWrite()
 }
 
-// CloseRead implements the ReadWriter CloseRead method.
-func (rw *DirectStreamReadWriter) CloseRead() error {
-	return rw.rw.CloseRead()
-}
-
 // Close implements the ReadWriter Close method.
 func (rw *DirectStreamReadWriter) Close() error {
 	return rw.rw.Close()

httpproxy/client.go

@@ -105,11 +105,6 @@ func (rw *directReadBufferedStreamReadWriter) CloseWrite() error {
 	return rw.rw.CloseWrite()
 }
 
-// CloseRead implements [zerocopy.ReadWriter.CloseRead].
-func (rw *directReadBufferedStreamReadWriter) CloseRead() error {
-	return rw.rw.CloseRead()
-}
-
 // Close implements [zerocopy.ReadWriter.Close].
 func (rw *directReadBufferedStreamReadWriter) Close() error {
 	return rw.rw.Close()

ss2022/stream.go

@@ -107,11 +107,6 @@ func (rw *ShadowStreamServerReadWriter) WriteZeroCopy(b []byte, payloadStart, pa
 	return rw.ShadowStreamWriter.WriteZeroCopy(b, payloadStart, payloadLen)
 }
 
-// CloseRead implements the ReadWriter CloseRead method.
-func (rw *ShadowStreamServerReadWriter) CloseRead() error {
-	return rw.rawRW.CloseRead()
-}
-
 // CloseWrite implements the ReadWriter CloseWrite method.
 func (rw *ShadowStreamServerReadWriter) CloseWrite() error {
 	return rw.rawRW.CloseWrite()
@@ -200,11 +195,6 @@ func (rw *ShadowStreamClientReadWriter) ReadZeroCopy(b []byte, payloadBufStart,
 	return rw.ShadowStreamReader.ReadZeroCopy(b, payloadBufStart, payloadBufLen)
 }
 
-// CloseRead implements the ReadWriter CloseRead method.
-func (rw *ShadowStreamClientReadWriter) CloseRead() error {
-	return rw.rawRW.CloseRead()
-}
-
 // CloseWrite implements the ReadWriter CloseWrite method.
 func (rw *ShadowStreamClientReadWriter) CloseWrite() error {
 	return rw.rawRW.CloseWrite()

zerocopy/stream.go

@@ -194,12 +194,6 @@ func relayFallback(w Writer, r Reader, frontHeadroom, rearHeadroom, readMaxPaylo
 	}
 }
 
-// CloseRead provides the CloseRead method.
-type CloseRead interface {
-	// CloseRead indicates to the underlying reader that no further reads will happen.
-	CloseRead() error
-}
-
 // CloseWrite provides the CloseWrite method.
 type CloseWrite interface {
 	// CloseWrite indicates to the underlying writer that no further writes will happen.
@@ -210,7 +204,6 @@ type CloseWrite interface {
 type ReadWriter interface {
 	Reader
 	Writer
-	CloseRead
 	CloseWrite
 	io.Closer
 }
@@ -241,7 +234,6 @@ func TwoWayRelay(left, right ReadWriter) (nl2r, nr2l int64, err error) {
 // DirectReadWriteCloser extends io.ReadWriteCloser with CloseRead and CloseWrite.
 type DirectReadWriteCloser interface {
 	io.ReadWriteCloser
-	CloseRead
 	CloseWrite
 }
 

zerocopy/stream_test.go

@@ -136,10 +136,6 @@ func (rw *testReadWriterImpl) RearHeadroom() int {
 	return 0
 }
 
-func (rw *testReadWriterImpl) CloseRead() error {
-	return nil
-}
-
 func (rw *testReadWriterImpl) CloseWrite() error {
 	return nil
 }
@@ -177,10 +173,6 @@ func (rw *testDirectReadWriter) RearHeadroom() int {
 	return 0
 }
 
-func (rw *testDirectReadWriter) CloseRead() error {
-	return nil
-}
-
 func (rw *testDirectReadWriter) CloseWrite() error {
 	return nil
 }