func TestServer_Response_LargeWrite_Concurrent(t *testing.T) {
    const size = 1 << 20
    const maxFrameSize = 16 << 10
    testServerResponse(t, func(w http.ResponseWriter, r *http.Request) error {
        n, err := w.Write(bytes.Repeat([]byte("a"), size))
        if err != nil {
            return fmt.Errorf("Write error: %v", err)
        }
        if n != size {
            return fmt.Errorf("wrong size %d from Write", n)
        }
        return nil
    }, func(st *serverTester) {
        if err := st.fr.WriteSettings(
            Setting{SettingInitialWindowSize, 0},
            Setting{SettingMaxFrameSize, maxFrameSize},
        ); err != nil {
            t.Fatal(err)
        }
        st.wantSettingsAck()

        nreqs := 1000
        streamID := uint32(1) // clients send odd ids
        for i := 0; i < nreqs; i++ {
            println("sending:", streamID)
            st.bodylessReq(streamID) // GET /
            // Give the handler quota to write:
            if err := st.fr.WriteWindowUpdate(streamID, size); err != nil {
                t.Fatal(err)
            }
            // Give the handler quota to write to connection-level
            // window as well
            if err := st.fr.WriteWindowUpdate(0, size); err != nil {
                t.Fatal(err)
            }
            streamID += 2
        }

        for {
            println("ReadFrame")
            f, err := st.fr.ReadFrame()
            if err != nil {
                panic(err)
            }
            println("nreqs:", nreqs)
            if es, ok := f.(streamEnder); ok && es.StreamEnded() {
                nreqs--
                if nreqs == 0 {
                    return
                }
            }
        }
    })
}