Updates

cmd/dendrite-demo-yggdrasil/main.go

@@ -72,15 +72,11 @@ func createFederationClient(
 	yggdialerctx := func(ctx context.Context, network, address string) (net.Conn, error) {
 		return yggdialer(network, address)
 	}
-
+	tr := &http.Transport{}
-	tr := &http.Transport{
-		MaxConnsPerHost: 1,
-	}
 	tr.RegisterProtocol(
 		"matrix", &yggroundtripper{
 			inner: &http.Transport{
-				DialContext:     yggdialerctx,
+				DialContext: yggdialerctx,
-				MaxConnsPerHost: 1,
 			},
 		},
 	)

cmd/dendrite-demo-yggdrasil/yggconn/stream.go

@@ -1,32 +0,0 @@
-package yggconn
-
-import (
-	"github.com/libp2p/go-yamux"
-)
-
-type stream struct {
-	*yamux.Stream
-	//conn net.Conn
-}
-
-/*
-func (c *stream) LocalAddr() net.Addr {
-	return c.LocalAddr()
-}
-
-func (c *stream) RemoteAddr() net.Addr {
-	return c.conn.RemoteAddr()
-}
-
-func (c *stream) SetDeadline(t time.Time) error {
-	return c.conn.SetDeadline(t)
-}
-
-func (c *stream) SetReadDeadline(t time.Time) error {
-	return c.conn.SetReadDeadline(t)
-}
-
-func (c *stream) SetWriteDeadline(t time.Time) error {
-	return c.conn.SetWriteDeadline(t)
-}
-*/