    @Test
    @Ignore("Null values no longer permitted")
    public void testSerializeDrainPhaseThrows() {

        final AtomicReference<Observer<Integer>> serial = new AtomicReference<Observer<Integer>>();
        TestObserver<Integer> to = new TestObserver<Integer>() {
            @Override
            public void onNext(Integer t) {
                if (t != null && t == 0) {
                    serial.get().onNext(null);
                } else
                if (t == null) {
                    throw new TestException();
                }
                super.onNext(t);
            }
        };

        SerializedObserver<Integer> sobs = new SerializedObserver<Integer>(to);
        serial.set(sobs);

        sobs.onNext(0);

        to.assertError(TestException.class);
        to.assertNotComplete();
    }