(conn net.Conn)
| 27 | } |
| 28 | |
| 29 | func (ss *StreamServer) Process(conn net.Conn) { |
| 30 | buf := new(bytes.Buffer) |
| 31 | for { |
| 32 | var size int64 |
| 33 | binary.Read(conn, binary.LittleEndian, &size) |
| 34 | |
| 35 | qtdBytes, err := io.CopyN(buf, conn, size) |
| 36 | if err != nil { |
| 37 | log.Fatal(err) |
| 38 | } |
| 39 | fmt.Println(buf.Bytes()) |
| 40 | fmt.Println("Received", qtdBytes, "bytes from client") |
| 41 | break |
| 42 | } |
| 43 | } |
| 44 | |
| 45 | func main() { |
| 46 | ss := &StreamServer{} |