@Test
public void overflowQueue() {

    Flowable.create(new FlowableOnSubscribe<Object>() {
        @Override
        public void subscribe(FlowableEmitter<Object> s) throws Exception {
            for (int i = 0; i < 10; i++) {
                s.onNext(i);
            }
        }
    }, BackpressureStrategy.MISSING)
    .publish(8)
    .autoConnect()
    .test(0L)
    .assertFailure(MissingBackpressureException.class);
}