closer - Code Search

build-logic/documentation/src/main/groovy/gradlebuild/docs/ReleaseNotesTransformer.java

                }
                return delegate.read(cbuf, off, len);
            }

            @Override
            public void close() throws IOException {
                if (delegate != null) {
                    delegate.close();
                }
            }
        };
        this.lock = this.in;
    }

    private Reader transform(Reader in) throws IOException {

Created: Wed Dec 31 11:36:14 GMT 2025

- Last Modified: Tue May 27 09:07:14 GMT 2025

- 11.7K bytes

- Click Count (0)

github.com/gradle/gradle

.github/workflows/issue-metadata.yml

name: Check issues metadata

on:
  issues:
    types: [ opened, labeled, unlabeled, closed, reopened, milestoned, demilestoned ]

permissions: {}

jobs:
  check_issue_metadata:
    permissions:
      issues: write
    runs-on: ubuntu-latest
    steps:
      # Check that issues have proper metadata: labels and milestone
      # https://github.com/gradle/issue-management-action/blob/main/src/issue-metadata.ts

Created: Wed Dec 31 11:36:14 GMT 2025

- Last Modified: Fri Aug 08 11:33:25 GMT 2025

- 474 bytes

- Click Count (0)

github.com/minio/minio

cmd/metacache-entries.go

}

// mergeEntryChannels will merge entries from in and return them sorted on out.
// To signify no more results are on an input channel, close it.
// The output channel will be closed when all inputs are emptied.
// If file names are equal, compareMeta is called to select which one to choose.
// The entry not chosen will be discarded.
// If the context is canceled the function will return the error,
// otherwise the function will return nil.

Created: Sun Dec 28 19:28:13 GMT 2025

- Last Modified: Thu Aug 08 15:29:58 GMT 2024

- 24.1K bytes

- Click Count (0)

github.com/minio/minio

cmd/grid.go

var globalLockGrid atomic.Pointer[grid.Manager]

// globalGridStart is a channel that will block startup of grid connections until closed.
var globalGridStart = make(chan struct{})

// globalLockGridStart is a channel that will block startup of lock grid connections until closed.
var globalLockGridStart = make(chan struct{})

func initGlobalGrid(ctx context.Context, eps EndpointServerPools) error {

Created: Sun Dec 28 19:28:13 GMT 2025

- Last Modified: Fri May 16 14:27:42 GMT 2025

- 3.7K bytes

- Click Count (0)

github.com/tiangolo/fastapi

.github/workflows/notify-translations.yml

name: Notify Translations

on:
  pull_request_target:
    types:
      - labeled
      - closed
  workflow_dispatch:
    inputs:
      number:
        description: PR number
        required: true
      debug_enabled:
        description: 'Run the build with tmate debugging enabled (https://github.com/marketplace/actions/debugging-with-tmate)'
        required: false
        default: 'false'

env:
  UV_SYSTEM_PYTHON: 1

Created: Sun Dec 28 07:19:09 GMT 2025

- Last Modified: Fri Nov 21 13:03:21 GMT 2025

- 1.7K bytes

- Click Count (0)

github.com/gradle/gradle

build-logic-commons/code-quality-rules/src/main/resources/classycle/classycle_report_resources.zip

+ "</td>"; } text += "</tr>"; } } text += "</table>"; } showText(text); } function showText(text) { list = window.open("", "list", "dependent=yes,location=no,menubar=yes,resizable=yes,toolbar=no,scrollbars=yes,width=500,height=400"); list.document.close(); list.document.open(); list.document.write("<html><head><style type=\"text/css\">"); list.document.write("body { font-family:Helvetica,Arial,sans-serif; } "); list.document.write(".link { cursor:pointer;text-decoration:underline; } "); list.document.writeln("th...

Created: Wed Dec 31 11:36:14 GMT 2025

- Last Modified: Wed Dec 09 08:14:05 GMT 2020

- 23.4K bytes

- Click Count (0)

github.com/tiangolo/fastapi

tests/test_http_connection_injection.py

@app.websocket("/ws")
async def get_value_by_ws(
    websocket: WebSocket, value: int = Depends(extract_value_from_http_connection)
):
    await websocket.accept()
    await websocket.send_json(value)
    await websocket.close()


client = TestClient(app)


def test_value_extracting_by_http():
    response = client.get("/http")
    assert response.status_code == 200
    assert response.json() == 42

Created: Sun Dec 28 07:19:09 GMT 2025

- Last Modified: Sun Aug 09 13:56:41 GMT 2020

- 972 bytes

- Click Count (0)

github.com/golang/go

src/Make.dist

# The -v causes dist to print the name of each directory as it runs.
# The -vv causes dist to print each build command as it runs.
# go tool dist clean cleans all directories, not just this one,
# but it's as close as we can get.

# Default target (first).
install:
	go tool dist install -v

verbose:
	go tool dist install -vv

clean:

Created: Tue Dec 30 11:13:12 GMT 2025

- Last Modified: Wed Feb 08 20:26:47 GMT 2012

- 553 bytes

- Click Count (0)

github.com/square/okhttp

okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/AddressPolicy.kt

 */
class AddressPolicy(
  /**
   * How many concurrent calls should be possible to make at any time.
   * The pool will routinely try to pre-emptively open connections to satisfy this minimum.
   * Connections will still be closed if they idle beyond the keep-alive but will be replaced.
   */
  @JvmField val minimumConcurrentCalls: Int = 0,
  /** How long to wait to retry pre-emptive connection attempts that fail. */

Created: Fri Dec 26 11:42:13 GMT 2025

- Last Modified: Tue Jun 03 17:10:08 GMT 2025

- 1.3K bytes

- Click Count (0)

github.com/google/guava

android/guava-tests/benchmark/com/google/common/collect/PowerSetBenchmark.java

@NullUnmarked
public class PowerSetBenchmark {
  @Param({"2", "4", "8", "16"})
  int elements;

  Set<Set<Integer>> powerSet;

  @BeforeExperiment
  void setUp() {
    Set<Integer> set = ContiguousSet.create(Range.closed(1, elements), integers());
    powerSet = Sets.powerSet(set);
  }

  @Benchmark
  int iteration(int reps) {
    int sum = 0;
    for (int i = 0; i < reps; i++) {
      for (Set<Integer> subset : powerSet) {

Created: Fri Dec 26 12:43:10 GMT 2025

- Last Modified: Thu Dec 19 18:03:30 GMT 2024

- 1.5K bytes

- Click Count (0)

Search Options