import (
  "net"
  "fmt"
  "io"
  "os"
  ymux "github.com/whyrusleeping/go-smux-yamux"
)
func dial() {
  nconn, _ := net.Dial("tcp", "localhost:1234")
  sconn, _ := ymux.DefaultTransport.NewConn(nconn, false) // false == client
  go func() {
    // no-op
    for {
      sconn.AcceptStream()
    }
  }()
  s1, _ := sconn.OpenStream()
  s1.Write([]byte("hello"))
  s2, _ := sconn.OpenStream()
  s2.Write([]byte("world"))
  length := 20
  buf2 := make([]byte, length)
  fmt.Printf("reading %d bytes from stream (echoed)\n", length)
  s1.Read(buf2)
  fmt.Printf("received %s as a response\n", string(buf2))
  s3, _ := sconn.OpenStream()
  io.Copy(s3, os.Stdin)
}

import (
  "net"
  "fmt"
  "io"
  smux "github.com/libp2p/go-stream-muxer"
  ymux "github.com/whyrusleeping/go-smux-yamux"
)
func listen() {
  tr := ymux.DefaultTransport
  l, _ := net.Listen("tcp", "localhost:1234")
  for {
    c, _ := l.Accept()
    fmt.Println("accepted connection")
    sc, _ := tr.NewConn(c, true)
    go func() {
      fmt.Println("serving connection")
      for {
        s, _ := sc.AcceptStream()
        echoStream(s)
      }
    }()
  }
}
func echoStream(s smux.Stream) {
  defer s.Close()
  fmt.Println("accepted stream")
  io.Copy(s, s) // echo everything
  fmt.Println("closing stream")
}