fixed timeout test for reactivex stream

Author: jell-o-fishi

tests/test_reactivex/test_reactivex_disconnect.py

@@ -4,10 +4,10 @@
 
 import pytest
 import reactivex
-from apscheduler.schedulers.asyncio import AsyncIOScheduler
 from reactivex import operators, Observable
 from reactivex.operators._tofuture import to_future_
 from reactivex.scheduler import ThreadPoolScheduler
+from reactivex.scheduler.eventloop import AsyncIOScheduler
 
 from rsocket.exceptions import RSocketProtocolError
 from rsocket.frame_helpers import ensure_bytes
@@ -45,7 +45,7 @@ async def request_stream(self, payload: Payload) -> Observable:
 
     async def request():
         await ReactiveXClient(client).request_stream(Payload(b'request text'),
-                                               request_limit=2).pipe(
+                                                     request_limit=2).pipe(
             operators.map(lambda payload: payload.data),
             operators.to_list(),
             to_future_(scheduler=AsyncIOScheduler(loop=asyncio.get_event_loop()))
@@ -61,4 +61,3 @@ async def request():
 
     with pytest.raises(RSocketProtocolError):
         await task
-