@Test
public void testSynchronousNext() {

    assertEquals(1, BehaviorSubject.create(1).take(1).toBlocking().single().intValue());
    assertEquals(2, BehaviorSubject.create(2).toBlocking().toIterable().iterator().next().intValue());
    assertEquals(3, BehaviorSubject.create(3).toBlocking().next().iterator().next().intValue());
}