migrate to rxpy v4

Author: MainRo

.gitignore

@@ -2,5 +2,8 @@ venv-rx
 *.pyc
 __pycache__
 *.egg-info
+.vscode
+.DS_Store
+notebook
 build
 dist

Chapter01/echo1.py

@@ -1,5 +1,5 @@
 import sys
-import rx
+import reactivex as rx
 
 argv = rx.from_(sys.argv[1:])
 

Chapter01/echo2.py

@@ -1,6 +1,6 @@
 import sys
-import rx
-import rx.operators as ops
+import reactivex as rx
+from reactivex import operators as ops
 
 argv = rx.from_(sys.argv[1:])
 argv = argv.pipe(

Chapter02/event_loop.py

@@ -9,5 +9,5 @@ async def wait(delay):
     print("waited for {} seconds at {}:{}:{}".format(delay, now.hour, now.minute, now.second))
     return True
 
-loop = asyncio.get_event_loop()
+loop = asyncio.new_event_loop()
 loop.run_until_complete(wait(2))

Chapter02/http_echo.py

@@ -15,7 +15,7 @@ async def start_server(runner):
 app.router.add_route('GET', '/echo/{what}', echo_handler)
 runner = web.AppRunner(app)
 
-loop = asyncio.get_event_loop()
+loop = asyncio.new_event_loop()
 loop.create_task(start_server(runner))
 
 loop.run_forever()

Chapter03/cycle_subject.py

@@ -1,6 +1,6 @@
-import rx
-import rx.operators as ops
-from rx.subject import Subject
+import reactivex as rx
+from reactivex import operators as ops
+from reactivex.subject import Subject
 
 
 def component_a(input):

Chapter03/rx_http_echo.py

@@ -1,8 +1,8 @@
 import asyncio
 from aiohttp import web
-import rx
-import rx.operators as ops
-from rx.subject import Subject
+import reactivex as rx
+from reactivex import operators as ops
+from reactivex.subject import Subject
 
 
 def http_driver(sink, loop):
@@ -26,6 +26,7 @@ async def on_request_data(request, path):
                 data, status = response_future.result()
 
                 response = web.StreamResponse(status=status, reason=None)
+                response.content_type = "text/plain"
                 await response.prepare(request)
                 if data is not None:
                     await response.write(data)
@@ -108,7 +109,7 @@ def echo_server(source):
 
 
 def main():
-    loop = asyncio.get_event_loop()
+    loop = asyncio.new_event_loop()
     http_proxy = Subject()
     sources = {
         'http': http_driver(http_proxy, loop),

Chapter04/catch_exception.py

@@ -1,5 +1,5 @@
-import rx
-import rx.operators as ops
+import reactivex as rx
+from reactivex import operators as ops
 
 
 err = rx.throw("error!")

Chapter04/create1.py

@@ -1,4 +1,4 @@
-import rx
+import reactivex as rx
 
 
 def on_subscribe(observer, scheduler):

Chapter04/create2.py

@@ -1,4 +1,4 @@
-import rx
+import reactivex as rx
 
 
 def sum_even(source):