please add a test that requests a few and cancels after the first one; this probably means implementing a synchronous Subscriber