fix: forward addr implementation for Proxy interface support

proxies/forward.go

@@ -22,15 +22,18 @@ func (f *Forward) Handle(client net.Conn) {
 	}
 }
 
+func (f *Forward) Addr() net.Addr {
+	return f.Listener.Addr()
+}
+
 func (f *Forward) Close() {
 	f.Listener.Close()
 }
 
-func (f *Forward) Serve() {
-	for {
-		client, aErr := f.Listener.Accept()
-		if aErr == nil {
-			go f.Handle(client)
-		}
+func (f *Forward) Serve() (err error) {
+	var client net.Conn
+	for client, err = f.Listener.Accept(); err == nil; client, err = f.Listener.Accept() {
+		go f.Handle(client)
 	}
+	return err
 }

proxies/forward_test.go

@@ -8,6 +8,39 @@ import (
 	"github.com/stretchr/testify/assert"
 )
 
+func TestForward_Addr(t *testing.T) {
+	listener := network.ListenAny()
+	defer listener.Close()
+	service := network.ListenAny()
+	defer service.Close()
+	f := Forward{
+		Network:  service.Addr().Network(),
+		Address:  service.Addr().String(),
+		Listener: listener,
+		Dial:     net.Dial,
+	}
+	defer f.Close()
+	doneChan := make(chan struct{}, 1)
+	defer close(doneChan)
+	testMessage := []byte("TEST")
+	go func() {
+		conn, aErr := service.Accept()
+		assert.Nil(t, aErr)
+		_, wErr := conn.Write(testMessage)
+		assert.Nil(t, wErr)
+		<-doneChan
+	}()
+	go f.Serve()
+	conn, dErr := net.Dial(listener.Addr().Network(), listener.Addr().String())
+	assert.Nil(t, dErr)
+	buffer := make([]byte, len(testMessage))
+	_, rErr := conn.Read(buffer)
+	assert.Nil(t, rErr)
+	assert.Equal(t, testMessage, buffer)
+	assert.NotNil(t, f.Addr())
+
+}
+
 func TestBasicLocalForward(t *testing.T) {
 	listener := network.ListenAny()
 	defer listener.Close()