INNER CODE UNIT · Go

_

docker/compose · relay/main_test.go:175

	_ = client.SetReadDeadline(time.Now().Add(5 * time.Second))
	for {
		n, err := client.Read(buf)
		got += n
		if err != nil {
			break
		}
	}
	if got < chunks*len("chunk") {
		t.Fatalf("streaming was cut by the idle reaper: got %d bytes, want %d", got, chunks*len("chunk"))
	}
	// let forward return before the Cleanup restores the shared grace var
	select {
	case <-finished:
	case <-time.After(5 * time.Second):
		t.Fatal("forward did not return after both directions ended")
	}
}

View source record →