- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 18 for testclosed (0.61 sec)
-
test/closedchan.go
func(c chan int) Chan { return SSChan(c) }, } var testcloseds = []func(Chan) { testasync1, testasync2, testasync3, testasync4, } func main() { for _, mk := range mks { test1(mk(closedsync())) } for _, testclosed := range testcloseds { for _, mk := range mks { testclosed(mk(closedasync())) } } var ch chan int shouldPanic(func() {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Feb 17 04:48:57 UTC 2012 - 5.8K bytes - Viewed (0) -
pkg/queue/instance_test.go
close(stop) }) select { case <-time.After(200 * time.Millisecond): t.Error("close stop, method exit timeout.") case <-signal: t.Log("queue return.") } } func TestClosed(t *testing.T) { t.Run("immediate close", func(t *testing.T) { stop := make(chan struct{}) q := NewQueue(0) go q.Run(stop) close(stop) if err := WaitForClose(q, 10*time.Second); err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jul 21 16:30:36 UTC 2023 - 3.4K bytes - Viewed (0) -
src/archive/tar/writer_test.go
} testReadFrom struct { // ReadFrom(testFile{ops}) == (wantCnt, wantErr) ops fileOps wantCnt int64 wantErr error } testClose struct { // Close() == wantErr wantErr error } testFnc any // testHeader | testWrite | testReadFrom | testClose ) vectors := []struct { file string // Optional filename of expected output tests []testFnc }{{
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 38.7K bytes - Viewed (0) -
pkg/kubelet/cm/cpumanager/state/state_test.go
See the License for the specific language governing permissions and limitations under the License. */ package state import ( "reflect" "testing" "k8s.io/utils/cpuset" ) func TestClone(t *testing.T) { expect := ContainerCPUAssignments{ "pod": map[string]cpuset.CPUSet{ "container1": cpuset.New(4, 5, 6), "container2": cpuset.New(1, 2, 3), }, } actual := expect.Clone()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 03 16:26:09 UTC 2023 - 935 bytes - Viewed (0) -
src/test/java/org/codelibs/core/io/CloseableUtilTest.java
import java.io.OutputStream; import org.junit.Test; /** * @author shot */ public class CloseableUtilTest { /** * @throws Exception */ @Test public void testClose() throws Exception { final NotifyOutputStream out = new NotifyOutputStream(); CloseableUtil.close(out); assertThat(out.getNotify(), is("closed")); } /** * @throws Exception
Registered: Wed Jun 12 12:50:12 UTC 2024 - Last Modified: Thu Mar 07 01:59:08 UTC 2024 - 2.2K bytes - Viewed (0) -
src/strings/clone_test.go
// Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. package strings_test import ( "strings" "testing" "unsafe" ) var emptyString string func TestClone(t *testing.T) { var cloneTests = []string{ "", strings.Clone(""), strings.Repeat("a", 42)[:0], "short", strings.Repeat("a", 42), } for _, input := range cloneTests {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jan 17 17:24:17 UTC 2023 - 1.1K bytes - Viewed (0) -
src/html/template/clone_test.go
err = added.ExecuteTemplate(b, "a", "1>0") if err != nil { t.Fatal(err) } if got, want := b.String(), ` 1>0 <a href=" 1%3e0 "></a>`; got != want { t.Errorf("got %q want %q", got, want) } } func TestClone(t *testing.T) { // The {{.}} will be executed with data "<i>*/" in different contexts. // In the t0 template, it will be in a text context. // In the t1 template, it will be in a URL context.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Sep 06 15:48:16 UTC 2022 - 8K bytes - Viewed (0) -
maven-core/src/test/java/org/apache/maven/project/MavenProjectTest.java
+ MavenProject.EMPTY_PROJECT_VERSION, project.getId()); } @Test void testClone() throws Exception { File f = getFileForClasspathResource("canonical-pom.xml"); MavenProject projectToClone = getProject(f); MavenProject clonedProject = projectToClone.clone();
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Sat Apr 15 17:24:20 UTC 2023 - 8K bytes - Viewed (0) -
pkg/kubelet/cm/topologymanager/numa_info_test.go
} result := numaInfo.NUMADistances.CalculateAverageFor(bm) if result != tcase.expectedAvg { t.Errorf("Expected result to equal %g, not %g", tcase.expectedAvg, result) } } } func TestClosest(t *testing.T) { tcases := []struct { description string current bitmask.BitMask candidate bitmask.BitMask expected string numaInfo *NUMAInfo }{ {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 09 16:52:14 UTC 2022 - 11.6K bytes - Viewed (0) -
src/maps/maps_test.go
t.Errorf("EqualFunc(%v, %v, equalNaN) = false, want true", mf, mf) } if !EqualFunc(m1, m2, equalIntStr) { t.Errorf("EqualFunc(%v, %v, equalIntStr) = false, want true", m1, m2) } } func TestClone(t *testing.T) { mc := Clone(m1) if !Equal(mc, m1) { t.Errorf("Clone(%v) = %v, want %v", m1, mc, m1) } mc[16] = 32 if Equal(mc, m1) { t.Errorf("Equal(%v, %v) = true, want false", mc, m1) } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Dec 05 17:05:56 UTC 2023 - 5.6K bytes - Viewed (0)