Java 类org.hamcrest.core.StringStartsWith 实例源码

项目：flink 文件：DataStreamTest.java

@Test
public void testPOJOWithNestedArrayNoHashCodeKeyRejection() {
    StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();

    DataStream<POJOWithHashCode> input = env.fromElements(
            new POJOWithHashCode(new int[] {1, 2}));

    TypeInformation<?> expectedTypeInfo = new TupleTypeInfo<Tuple1<int[]>>(
            PrimitiveArrayTypeInfo.INT_PRIMITIVE_ARRAY_TYPE_INFO);

    // adjust the rule
    expectedException.expect(InvalidProgramException.class);
    expectedException.expectMessage(new StringStartsWith("Type " + expectedTypeInfo + " cannot be used as key."));

    input.keyBy("id");
}

项目：flink 文件：DataStreamTest.java

@Test
public void testTupleNestedArrayKeyRejection() {
    StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();

    DataStream<Tuple2<Integer[], String>> input = env.fromElements(
            new Tuple2<>(new Integer[] {1, 2}, "test-test"));

    TypeInformation<?> expectedTypeInfo = new TupleTypeInfo<Tuple2<Integer[], String>>(
            BasicArrayTypeInfo.INT_ARRAY_TYPE_INFO, BasicTypeInfo.STRING_TYPE_INFO);

    // adjust the rule
    expectedException.expect(InvalidProgramException.class);
    expectedException.expectMessage(new StringStartsWith("Type " + expectedTypeInfo + " cannot be used as key."));

    input.keyBy(new KeySelector<Tuple2<Integer[], String>, Tuple2<Integer[], String>>() {
        @Override
        public Tuple2<Integer[], String> getKey(Tuple2<Integer[], String> value) throws Exception {
            return value;
        }
    });
}

项目：simple-json-rpc 文件：BatchRequestBuilderErrors.java

@Test
public void testNotJsonResponse() {
    thrown.expect(IllegalStateException.class);
    thrown.expectMessage(new StringStartsWith("Unable parse a JSON response"));

    JsonRpcClient client = new JsonRpcClient(new Transport() {
        @NotNull
        @Override
        public String pass(@NotNull String request) throws IOException {
            return "test data";
        }
    });
    client.createBatchRequest()
            .add(1L, "findPlayer", "Steven", "Stamkos")
            .add(2L, "findPlayer", "Vladimir", "Sobotka")
            .returnType(Player.class)
            .execute();
}

项目：simple-json-rpc 文件：BatchRequestBuilderErrors.java

@Test
public void testNoVersion() {
    thrown.expect(IllegalStateException.class);
    thrown.expectMessage(new StringStartsWith("Not a JSON-RPC response"));

    JsonRpcClient client = new JsonRpcClient(new Transport() {
        @NotNull
        @Override
        public String pass(@NotNull String request) throws IOException {
            return "[{\"test\":\"data\"}]";
        }
    });
    client.createBatchRequest()
            .add(1L, "findPlayer", "Steven", "Stamkos")
            .add(2L, "findPlayer", "Vladimir", "Sobotka")
            .returnType(Player.class)
            .execute();
}

项目：simple-json-rpc 文件：BatchRequestBuilderErrors.java

@Test
public void testUnexpectedResult() {
    thrown.expect(IllegalStateException.class);
    thrown.expectMessage(new StringStartsWith("Neither result or error is set in response"));

    JsonRpcClient client = new JsonRpcClient(new Transport() {
        @NotNull
        @Override
        public String pass(@NotNull String request) throws IOException {
            return "[{\n" +
                    "    \"jsonrpc\": \"2.0\",\n" +
                    "    \"id\": 1\n" +
                    "}]";
        }
    });
    client.createBatchRequest()
            .add(1L, "findPlayer", "Steven", "Stamkos")
            .add(2L, "findPlayer", "Vladimir", "Sobotka")
            .returnType(Player.class)
            .execute();
}

项目：elastic-job-cloud 文件：RestfulServerTest.java

@Test
public void assertCallFailure() throws Exception {
    ContentExchange actual = sentRequest("{\"string\":\"test\",\"integer\":\"invalid_number\"}");
    Assert.assertThat(actual.getResponseStatus(), Is.is(500));
    Assert.assertThat(actual.getResponseContent(), StringStartsWith.startsWith("java.lang.NumberFormatException"));
    Mockito.verify(caller).call("test");
}

项目：nifi-android-s2s 文件：PeerTrackerTest.java

@Test
public void testUnsuccessfulResponseCode() throws IOException {
    expectedException.expect(IOException.class);
    expectedException.expectMessage(new StringStartsWith(RECEIVED_RESPONSE_CODE));

    mockNiFiS2SServer.getMockWebServer().enqueue(new MockResponse().setResponseCode(400));

    new HttpSiteToSiteClient(siteToSiteClientConfig, siteToSiteRemoteCluster);
}