add unit test for closing connections before update onNext
add unit test for committing and rolling back connections before update onNext
add comment