Grappler - Code Search

guava-tests/test/com/google/common/util/concurrent/ForwardingExecutorServiceTest.java

          }
        };
    ExecutorService wrapper =
        new ForwardingExecutorService() {
          @Override
          protected ExecutorService delegate() {
            return delegate;
          }
        };
    Method closeMethod;
    try {
      closeMethod = wrapper.getClass().getMethod("close");
    } catch (NoSuchMethodException e) {

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Sat Mar 07 02:20:33 GMT 2026

- 2.9K bytes

- Click Count (0)

github.com/google/guava

android/guava-testlib/src/com/google/common/testing/ForwardingWrapperTester.java

      T wrapper = wrapperFunction.apply(proxy);
      boolean isPossibleChainingCall = interfaceType.isAssignableFrom(method.getReturnType());
      try {
        Object actualReturnValue = method.invoke(wrapper, passedArgs);
        // If we think this might be a 'chaining' call then we allow the return value to either
        // be the wrapper or the returnValue.

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Tue May 13 17:27:14 GMT 2025

- 9.1K bytes

- Click Count (0)

github.com/minio/minio

cmd/object_api_suite_test.go

	eof  bool
	data []byte
}

func (r *testOneByteReadNoEOF) Read(p []byte) (n int, err error) {
	if r.eof {
		return 0, io.EOF
	}
	n = copy(p, r.data)
	r.eof = true
	return n, nil
}

// Wrapper for calling testMakeBucket for both Erasure and FS.
func TestMakeBucket(t *testing.T) {
	ExecObjectLayerTest(t, testMakeBucket)
}

// Tests validate bucket creation.

Created: Sun Apr 05 19:28:12 GMT 2026

- Last Modified: Fri Aug 29 02:39:48 GMT 2025

- 34.5K bytes

- Click Count (0)

github.com/gradle/gradle

build-logic/cleanup/src/main/kotlin/gradlebuild/cleanup/services/CachesCleaner.kt

        // Remove old distributions used by wrapper that we're unlikely to ever require again
        fileSystemOperations.removeOldVersionsFromDir(workerDir.dir("wrapper/dists"), expireDistributionCache, "gradle-", "-bin")
        fileSystemOperations.delete {
            delete(workerDir.dir("wrapper/dists/dist"))
        }

        // Remove caches that weren't multi-process safe and may be corrupt

Created: Wed Apr 01 11:36:16 GMT 2026

- Last Modified: Fri Jun 28 08:29:28 GMT 2024

- 4.2K bytes

- Click Count (1)

github.com/codelibs/jcifs

src/test/java/jcifs/smb1/util/transport/TransportExceptionTest.java

            // Wrap in another exception
            TransportException wrapper = new TransportException("Wrapper", original);

            assertEquals("Wrapper", wrapper.getMessage());
            assertEquals(original, wrapper.getRootCause());
            assertEquals(originalMessage, ((TransportException) wrapper.getRootCause()).getMessage());
        }
    }

Created: Sun Apr 05 00:10:12 GMT 2026

- Last Modified: Thu Aug 14 05:31:44 GMT 2025

- 11.5K bytes

- Click Count (0)

github.com/google/guava

.gitignore

# Maven
target/
*.ser
*.ec
.mvn/wrapper/maven-wrapper.jar

# IntelliJ Idea
.idea/
out/
*.ipr
*.iws
*.iml

# Eclipse
.classpath
.project
.settings/
.metadata/

# OS X

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Tue Oct 17 16:57:55 GMT 2023

- 176 bytes

- Click Count (0)

github.com/apache/maven

Jenkinsfile

               "MAVEN_OPTS=-Xms4G -Xmx4G -Djava.awt.headless=true"]) {
        sh "mvn --errors --batch-mode --show-version org.apache.maven.plugins:maven-wrapper-plugin:3.3.4:wrapper -Dmaven=3.9.12"
        sh "echo run Its"
        sh "./mvnw -e -B -V install $extraArgs"
      }
    }
    finally {
      junit testResults: '**/target/test-results-surefire/*.xml', allowEmptyResults: true

Created: Sun Apr 05 03:35:12 GMT 2026

- Last Modified: Mon Jan 26 16:20:31 GMT 2026

- 2K bytes

- Click Count (0)

github.com/codelibs/jcifs

src/test/java/jcifs/pac/kerberos/KerberosTokenTest.java

        DERSequence wrongTag = new DERSequence(new ASN1Encodable[] { new ASN1Integer(5) });
        innerContent.write(wrongTag.getEncoded());

        byte[] content = innerContent.toByteArray();

        // Create GSS-API wrapper
        ByteArrayOutputStream baos = new ByteArrayOutputStream();
        baos.write(0x60); // APPLICATION 0
        baos.write(content.length);
        baos.write(content);

        byte[] token = baos.toByteArray();

Created: Sun Apr 05 00:10:12 GMT 2026

- Last Modified: Thu Aug 14 05:31:44 GMT 2025

- 6.8K bytes

- Click Count (0)

github.com/tiangolo/fastapi

tests/test_custom_middleware_exception.py

        if scope["type"] != "http" or self.max_content_size is None:
            await self.app(scope, receive, send)
            return

        wrapper = self.receive_wrapper(receive)
        await self.app(scope, wrapper, send)


@router.post("/middleware")
def run_middleware(file: UploadFile = File(..., description="Big File")):
    return {"message": "OK"}


app.include_router(router)

Created: Sun Apr 05 07:19:11 GMT 2026

- Last Modified: Tue Feb 17 09:59:14 GMT 2026

- 2.8K bytes

- Click Count (0)

github.com/codelibs/fess

src/main/webapp/WEB-INF/view/admin/sereq/admin_sereq.jsp

</head>
<body class="hold-transition sidebar-mini">
	<div class="wrapper">
		<jsp:include page="/WEB-INF/view/common/admin/header.jsp"></jsp:include>
		<jsp:include page="/WEB-INF/view/common/admin/sidebar.jsp">
			<jsp:param name="menuCategoryType" value="system" />
			<jsp:param name="menuType" value="sereq" />
		</jsp:include>
		<main class="content-wrapper">
			<div class="content-header">
				<div class="container-fluid">

Created: Tue Mar 31 13:07:34 GMT 2026

- Last Modified: Mon Feb 23 08:03:44 GMT 2026

- 2.3K bytes

- Click Count (0)

Search Options