@@ -21,6 +21,9 @@ func NewVectorisedWriter(writer io.Writer) N.VectorisedWriter {
 }
 
 func CreateVectorisedWriter(writer any) (N.VectorisedWriter, bool) {
+	if vectorisedCreator, isVectorisedCreator := writer.(N.VectorisedWriteCreator); isVectorisedCreator {
+		return vectorisedCreator.CreateVectorisedWriter()
+	}
 	if runtime.GOOS == "windows" {
 		switch conn := writer.(type) {
 		case N.VectorisedWriter:
@@ -48,6 +51,14 @@ func CreateVectorisedWriter(writer any) (N.VectorisedWriter, bool) {
 			return &SyscallVectorisedWriter{upstream: writer, rawConn: conn}, true
 		}
 	}
+	if u, ok := writer.(N.WriterWithUpstream); ok && u.WriterReplaceable() {
+		if u, ok := writer.(N.WithUpstreamWriter); ok {
+			return CreateVectorisedWriter(u.UpstreamWriter())
+		}
+		if u, ok := writer.(common.WithUpstream); ok {
+			return CreateVectorisedWriter(u.Upstream())
+		}
+	}
 	return nil, false
 }
 
 
@@ -9,6 +9,10 @@ type VectorisedWriter interface {
 	WriteVectorised(buffers []*buf.Buffer) error
 }
 
+type VectorisedWriteCreator interface {
+	CreateVectorisedWriter() (VectorisedWriter, bool)
+}
+
 type VectorisedPacketWriter interface {
 	WriteVectorisedPacket(buffers []*buf.Buffer, destination M.Socksaddr) error
 }
Original file line number	Diff line number	Diff line change
`@@ -21,6 +21,9 @@ func NewVectorisedWriter(writer io.Writer) N.VectorisedWriter {`
`21`	`21`	`}`
`22`	`22`
`23`	`23`	`func CreateVectorisedWriter(writer any) (N.VectorisedWriter, bool) {`
	`24`	`+ if vectorisedCreator, isVectorisedCreator := writer.(N.VectorisedWriteCreator); isVectorisedCreator {`
	`25`	`+ return vectorisedCreator.CreateVectorisedWriter()`
	`26`	`+ }`
`24`	`27`	`if runtime.GOOS == "windows" {`
`25`	`28`	`switch conn := writer.(type) {`
`26`	`29`	`case N.VectorisedWriter:`
`@@ -48,6 +51,14 @@ func CreateVectorisedWriter(writer any) (N.VectorisedWriter, bool) {`
`48`	`51`	`return &SyscallVectorisedWriter{upstream: writer, rawConn: conn}, true`
`49`	`52`	`}`
`50`	`53`	`}`
	`54`	`+ if u, ok := writer.(N.WriterWithUpstream); ok && u.WriterReplaceable() {`
	`55`	`+ if u, ok := writer.(N.WithUpstreamWriter); ok {`
	`56`	`+ return CreateVectorisedWriter(u.UpstreamWriter())`
	`57`	`+ }`
	`58`	`+ if u, ok := writer.(common.WithUpstream); ok {`
	`59`	`+ return CreateVectorisedWriter(u.Upstream())`
	`60`	`+ }`
	`61`	`+ }`
`51`	`62`	`return nil, false`
`52`	`63`	`}`
`53`	`64`
Original file line number	Diff line number	Diff line change
`@@ -9,6 +9,10 @@ type VectorisedWriter interface {`
`9`	`9`	`WriteVectorised(buffers []*buf.Buffer) error`
`10`	`10`	`}`
`11`	`11`
	`12`	`+type VectorisedWriteCreator interface {`
	`13`	`+ CreateVectorisedWriter() (VectorisedWriter, bool)`
	`14`	`+}`
	`15`	`+`
`12`	`16`	`type VectorisedPacketWriter interface {`
`13`	`17`	`WriteVectorisedPacket(buffers []*buf.Buffer, destination M.Socksaddr) error`
`14`	`18`	`}`