connection.go

func(c *Connection) manage() {
    buffer := make([]byte, 1000) 
    for {
        select {
        case out := <-c.outgoing:
            c.socket.Write(out)

        default:
            n, err := c.socket.Read(buffer) 
            if err != nil {
                panic(err) // do this later
            }
            if n > 0 {
                for _, listener := range c.listeners {
                    // nonblocking send
                    select {
                    case listener <- buffer[:n]:
                    default: 
                    }
                }
            }
    }
}