@Test
public void scalarMapToEmpty() {

    FlowableScalarXMap.scalarXMap(1, new Function<Integer, Publisher<Integer>>() {
        @Override
        public Publisher<Integer> apply(Integer v) throws Exception {
            return Flowable.empty();
        }
    })
    .test()
    .assertResult();
}