clase - Code Search

src/test/java/jcifs/SmbWatchHandleTest.java

        doThrow(expectedException).when(watchHandle).close();

        // Execute and verify
        CIFSException thrown = assertThrows(CIFSException.class, () -> {
            watchHandle.close();
        });

        assertEquals("Failed to close handle", thrown.getMessage());
        verify(watchHandle, times(1)).close();
    }

    /**

Created: Sat Dec 20 13:44:44 GMT 2025

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

- 13.2K bytes

- Click Count (1)

github.com/codelibs/jcifs

src/main/java/jcifs/smb1/http/NetworkExplorer.java

        out.println("</head><body>");

        out.print("<a class=\"sort\" style=\"width: " + maxLen + ";\" href=\"?fmt=detail&sort=name\">Name</a>");
        out.println("<a class=\"sort\" href=\"?fmt=detail&sort=size\">Size</a>");
        out.println("<a class=\"sort\" href=\"?fmt=detail&sort=type\">Type</a>");
        out.println("<a class=\"sort\" style=\"width: 180\" href=\"?fmt=detail&sort=date\">Modified</a><br clear='all'><p>");

Created: Sat Dec 20 13:44:44 GMT 2025

- Last Modified: Sun Aug 31 08:00:57 GMT 2025

- 22.6K bytes

- Click Count (0)

github.com/codelibs/jcifs

src/test/java/jcifs/dcerpc/msrpc/LsaPolicyHandleTest.java

        }).when(mockDcerpcHandle).sendrecv(any(MsrpcLsarClose.class));

        // Close once
        handle.close();

        // Act
        // Try to close again
        handle.close();

        // Assert
        // Verify sendrecv was called once for open and only once for close
        verify(mockDcerpcHandle, times(1)).sendrecv(any(MsrpcLsarOpenPolicy2.class));

Created: Sat Dec 20 13:44:44 GMT 2025

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

- 8.9K bytes

- Click Count (0)

github.com/google/guava

guava/src/com/google/common/collect/Streams.java

                  return true;
                }
                return false;
              }
            },
            isParallel)
        .onClose(streamA::close)
        .onClose(streamB::close);
  }

  /**
   * Invokes {@code consumer} once for each pair of <i>corresponding</i> elements in {@code streamA}

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

- Last Modified: Sat Aug 09 01:14:59 GMT 2025

- 36.4K bytes

- Click Count (0)

github.com/minio/minio

internal/s3select/csv/reader.go

	// Start splitter
	go func() {
		defer close(r.input)
		defer close(r.queue)
		defer r.readerWg.Done()
		for {
			q := queueItem{
				input: next,
				dst:   make(chan [][]string, 1),
				err:   nextErr,
			}
			select {
			case <-r.close:
				return
			case r.queue <- &q:
			}

			select {
			case <-r.close:
				return
			case r.input <- &q:
			}
			if nextErr != nil {

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

- Last Modified: Tue May 27 15:19:03 GMT 2025

- 8.8K bytes

- Click Count (0)

github.com/codelibs/jcifs

src/main/java/jcifs/smb1/smb1/SmbFile.java

    }

    void close(final int f, final long lastWriteTime) throws SmbException {

        if (LogStream.level >= 3) {
            log.println("close: " + f);
        }

        /*
         * Close Request / Response
         */

        send(new SmbComClose(f, lastWriteTime), blank_resp());
    }

    void close(final long lastWriteTime) throws SmbException {

Created: Sat Dec 20 13:44:44 GMT 2025

- Last Modified: Sat Aug 30 05:58:03 GMT 2025

- 112.2K bytes

- Click Count (0)

github.com/square/okhttp

okhttp/src/jvmTest/kotlin/okhttp3/EventListenerTest.kt

      CallStart::class,
      ProxySelectStart::class,
      ProxySelectEnd::class,
      DnsStart::class,
      DnsEnd::class,
      ConnectStart::class,
      ConnectEnd::class,
      ConnectionAcquired::class,
      RequestHeadersStart::class,
      RequestHeadersEnd::class,
      ResponseFailed::class,
      RetryDecision::class,
      ConnectionReleased::class,

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

- Last Modified: Wed Nov 05 18:28:35 GMT 2025

- 70.5K bytes

- Click Count (0)

github.com/square/okhttp

okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/MockHttp2Peer.kt

  @Synchronized override fun close() {
    executor.shutdown()
    socket?.closeQuietly()
    serverSocket?.closeQuietly()
  }

  override fun toString(): String = "MockHttp2Peer[$port]"

  private class OutFrame(
    val sequence: Int,
    val start: Long,
    val truncated: Boolean,
  )

  class InFrame(
    val sequence: Int,
    val reader: Http2Reader,

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

- Last Modified: Wed Mar 19 19:25:20 GMT 2025

- 8.7K bytes

- Click Count (0)

github.com/tiangolo/fastapi

docs/es/docs/features.md

* <a href="https://github.com/swagger-api/swagger-ui" class="external-link" target="_blank"><strong>Swagger UI</strong></a>, con exploración interactiva, llama y prueba tu API directamente desde el navegador.

![Interacción Swagger UI](https://fastapi.tiangolo.com/img/index/index-03-swagger-02.png)

* Documentación alternativa de API con <a href="https://github.com/Rebilly/ReDoc" class="external-link" target="_blank"><strong>ReDoc</strong></a>.

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

- Last Modified: Wed Dec 17 10:15:01 GMT 2025

- 10.8K bytes

- Click Count (0)

github.com/codelibs/jcifs

src/main/java/jcifs/internal/smb1/trans2/Trans2QueryFSInformationResponse.java

        AllocInfo inf;
        switch (this.informationLevel) {
        case FileSystemInformation.SMB_INFO_ALLOCATION:
            inf = new SmbInfoAllocation();
            break;
        case FileSystemInformation.FS_SIZE_INFO:
            inf = new FileFsSizeInformation();
            break;
        case FileSystemInformation.FS_FULL_SIZE_INFO:
            inf = new FileFsFullSizeInformation();

Created: Sat Dec 20 13:44:44 GMT 2025

- Last Modified: Sat Aug 16 01:32:48 GMT 2025

- 5K bytes

- Click Count (0)

Search Options