@Test
public void createWithError() {

    Exception failure = new Exception("Boom");
    PublisherStage<Object> boom = factory.create(null, () -> failure);
    TestSubscriber<Object> test = boom.get().test();
    test.assertError(failure);
}