}
		})
	}
}

func TestCSVQueries2(t *testing.T) {
	testInput := []byte(`id,time,num,num2,text
1,2010-01-01T,7867786,4565.908123,"a text, with comma"
2,2017-01-02T03:04Z,-5, 0.765111,
`)
	testTable := []struct {
		name       string
		query      string
		input      []byte
		requestXML []byte // override request XML

        assertEquals(0, new BigDecimal("0.123").compareTo(BigDecimalConversionUtil.toBigDecimal(Double.valueOf(0.123D))));
        assertEquals(0, new BigDecimal("0.0123").compareTo(BigDecimalConversionUtil.toBigDecimal(Double.valueOf(0.0123D))));
        assertEquals(0, new BigDecimal("0.00123").compareTo(BigDecimalConversionUtil.toBigDecimal(Double.valueOf(0.00123D))));

        assertVersionOlder("2.0.1-klm-SNAPSHOT", "2.0.1-lmn-SNAPSHOT");
        // assertVersionOlder( "2.0.1-xyz-SNAPSHOT", "2.0.1-SNAPSHOT" );
        assertVersionOlder("2.0.1-SNAPSHOT", "2.0.1-123-SNAPSHOT");
        assertVersionOlder("2.0.1-xyz-SNAPSHOT", "2.0.1-123-SNAPSHOT");
    }

    @Test
    void testSnapshotVsReleases() {
        assertVersionOlder("1.0-RC1", "1.0-SNAPSHOT");
        assertVersionOlder("1.0-rc1", "1.0-SNAPSHOT");

        // Given - Create a custom implementation
        BasicFileInformation customImpl = new BasicFileInformation() {
            @Override
            public int getAttributes() {
                return 0x123;
            }

            @Override
            public long getCreateTime() {
                return 999L;
            }

            @Override
            public long getLastWriteTime() {

    }

    @Test
    void testEncodeWritesCorrectHeader() throws Exception {
        TestMessage m = new TestMessage();
        m.ptype = 0;
        m.flags = 0x05;
        m.call_id = 0x123;

        NdrBuffer buf = new NdrBuffer(new byte[1024], 0);
        m.encode(buf);

        // Reset to read what was written
        buf.setIndex(0);

        // Verify header was written correctly

  }

  public void testFlatMapToInt_nullStream() {
    SpliteratorTester.ofInt(
            () ->
                CollectSpliterators.flatMapToInt(
                    Arrays.spliterator(new Integer[] {1, 0, 1, 2, 3}),
                    (Integer i) -> i == 0 ? null : IntStream.of(i).spliterator(),
                    Spliterator.SIZED | Spliterator.DISTINCT | Spliterator.NONNULL,
                    4))
        .expect(1, 1, 2, 3);

- PodDisruptionBudget API objects can now contain conditions in status. ([#98127](https://github.com/kubernetes/kubernetes/pull/98127), [@mortent](https://github.com/mortent)) [SIG API Machinery, Apps, Auth, CLI, Cloud Provider, Cluster Lifecycle and Instrumentation]

	// These should not be connectable.
	endpoint, err := NewEndpoint("http://localhost:9876")
	if err != nil {
		t.Fatalf("unexpected error %v", err)
	}
	endpointLocal, err := NewEndpoint("http://localhost:9012")
	if err != nil {
		t.Fatalf("unexpected error %v", err)
	}
	endpointLocal.IsLocal = true

	ctx, cancel := context.WithCancel(t.Context())
	defer cancel()

    class ParameterizedInit {
        static Stream<Arguments> validRanges() {
            byte[] src = new byte[] { 0, 1, 2, 3 };
            return Stream.of(Arguments.of(src, 0, 0, new byte[] {}), Arguments.of(src, 0, 4, new byte[] { 0, 1, 2, 3 }),
                    Arguments.of(src, 1, 2, new byte[] { 1, 2 }), Arguments.of(src, 3, 1, new byte[] { 3 }));
        }

			<plugin>
				<artifactId>maven-surefire-plugin</artifactId>
				<version>3.5.3</version>
			</plugin>
			<plugin>
				<groupId>org.jacoco</groupId>
				<artifactId>jacoco-maven-plugin</artifactId>
				<version>0.8.13</version>
				<executions>
					<execution>
						<goals>
							<goal>prepare-agent</goal>
						</goals>
					</execution>
					<execution>
						<id>report</id>
						<phase>prepare-package</phase>