// 32-bit decimal input.
func ExampleScanner_custom() {
	// An artificial input source.
	const input = "1234 5678 1234567901234567890"
	scanner := bufio.NewScanner(strings.NewReader(input))
	// Create a custom split function by wrapping the existing ScanWords function.
	split := func(data []byte, atEOF bool) (advance int, token []byte, err error) {
		advance, token, err = bufio.ScanWords(data, atEOF)

    void setUp() {
        response = new SrvCopyChunkCopyResponse();
    }

    @Nested
    @DisplayName("Constructor Tests")
    class ConstructorTests {

        @Test
        @DisplayName("Should create response with default values")
        void testConstructor() {
            SrvCopyChunkCopyResponse copyResponse = new SrvCopyChunkCopyResponse();
            assertNotNull(copyResponse);
        }

        @Test

    assertThrows(IndexOutOfBoundsException.class, () -> sink.putBytes(new byte[8], 0, 16));
    assertThrows(IndexOutOfBoundsException.class, () -> sink.putBytes(new byte[8], 0, -1));
  }

  /**
   * This test creates a long random sequence of inputs, then a lot of differently configured sinks
   * process it; all should produce the same answer, the only difference should be the number of

            InetAddress serverAddress,
            WitnessNotificationListener listener) {
        
        return CompletableFuture.supplyAsync(() -> {
            try {
                // Create registration
                WitnessRegistration registration = new WitnessRegistration(
                    shareName, serverAddress, WitnessServiceType.FILE_SERVER_WITNESS);
                

// This is usually orders of magnitude faster than actually sorting.
func (m metaCacheEntries) isSorted() bool {
	return sort.SliceIsSorted(m, m.less)
}

// shallowClone will create a shallow clone of the array objects,
// but object metadata will not be cloned.
func (m metaCacheEntries) shallowClone() metaCacheEntries {
	dst := make(metaCacheEntries, len(m))
	copy(dst, m)
	return dst
}

        void testReadStringWithMaxLengthAndSrcEnd() {
            testBlock.setUseUnicode(false);
            when(mockConfig.getOemEncoding()).thenReturn("UTF-8");

            // Create a buffer with null terminator within the max length
            byte[] buffer = new byte[20];
            System.arraycopy("Test".getBytes(), 0, buffer, 0, 4);
            buffer[4] = 0; // null terminator

        this.delegate = treeConnection;
    }

    static SmbTreeConnection create(final CIFSContext c) {
        if (c.getConfig().isTraceResourceUsage()) {
            return new SmbTreeConnectionTrace(c);
        }
        return new SmbTreeConnection(c);
    }

    static SmbTreeConnection create(final SmbTreeConnection c) {
        if (c.ctx.getConfig().isTraceResourceUsage()) {

            // Given: Original value that fits in byte range
            int originalValue = 150;
            NdrShort ndrShort1 = new NdrShort(originalValue);

            // Create separate mocks for encoding and decoding to simulate real buffer
            NdrBuffer encodeBuffer = mock(NdrBuffer.class);
            NdrBuffer decodeBuffer = mock(NdrBuffer.class);

      "coverage" : {
        "per_commit" : [ "linux" ]
      }
    } ]
  }, {
    "testId" : "org.gradle.performance.regression.corefeature.DeprecationCreationPerformanceTest.create many deprecation warnings",
    "groups" : [ {
      "testProject" : "generateLotsOfDeprecationWarnings",
      "coverage" : {
        "per_day" : [ "linux" ]
      }
    } ]
  }, {

				return
			default:
				// There was error in the REST request, retry after sometime as probably the peer is down.
				time.Sleep(5 * time.Second)
			}
		}
	}()
}

// newPeerRestClients creates new peer clients.
// The two slices will point to the same clients,
// but 'all' will contain nil entry for local client.
// The 'all' slice will be in the same order across the cluster.