public static Read readResources() {
    return new Read();
  }
@Test
  public void test_FhirIO_failedReads() {
    List<String> badMessageIDs = Arrays.asList("foo", "bar");
    FhirIO.Read.Result readResult =
        pipeline.apply(Create.of(badMessageIDs)).apply(FhirIO.readResources());

    PCollection<HealthcareIOError<String>> failed = readResult.getFailedReads();

    PCollection<String> resources = readResult.getResources();

    PCollection<String> failedMsgIds =
        failed.apply(
            MapElements.into(TypeDescriptors.strings()).via(HealthcareIOError::getDataResource));

    PAssert.that(failedMsgIds).containsInAnyOrder(badMessageIDs);
    PAssert.that(resources).empty();
    pipeline.run();
  }