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):

Chapter04/dispose.py

@@ -1,4 +1,4 @@
-import rx
+import reactivex as rx
 
 
 numbers = rx.from_([1, 2, 3])

Chapter04/from_callback.py

@@ -1,4 +1,4 @@
-import rx
+import reactivex as rx
 
 
 def foo(what, handler):

Chapter04/from_future.py

@@ -1,4 +1,4 @@
-import rx
+import reactivex as rx
 import asyncio
 
 
@@ -7,9 +7,10 @@ async def foo(future):
     future.set_result(2)
 
 
-loop = asyncio.get_event_loop()
+loop = asyncio.new_event_loop()
+asyncio.set_event_loop(loop)
 done = loop.create_future()
-asyncio.ensure_future(foo(done))
+t = asyncio.ensure_future(foo(done), loop=loop)
 
 number = rx.from_future(done)
 print("subscribing...")
@@ -20,5 +21,5 @@ async def foo(future):
 )
 
 print("staring mainloop")
-loop.run_until_complete(done)
+loop.run_until_complete(t)
 loop.close()

Chapter04/interval.py

@@ -1,4 +1,4 @@
-import rx
+import reactivex as rx
 import datetime
 import time
 

Chapter04/just.py

@@ -1,4 +1,4 @@
-import rx
+import reactivex as rx
 
 number = rx.just(1)
 number.subscribe(

Chapter04/of1.py

@@ -1,4 +1,4 @@
-import rx
+import reactivex as rx
 
 numbers = rx.of(1, 2, 3, 4)
 numbers.subscribe(

Chapter04/of2.py

@@ -1,4 +1,4 @@
-import rx
+import reactivex as rx
 
 
 def create_numbers_observable(*args):

Chapter04/publish_connect1.py

@@ -1,5 +1,6 @@
-import rx
-import rx.operators as ops
+import reactivex as rx
+from reactivex import operators as ops
+
 
 numbers = rx.from_([1, 2, 3])
 pub_numbers = numbers.pipe(ops.publish())

Chapter04/publish_connect2.py

@@ -1,5 +1,5 @@
-import rx
-import rx.operators as ops
+import reactivex as rx
+from reactivex import operators as ops
 
 
 numbers = rx.from_([1, 2, 3])

Chapter04/publish_connect3.py

@@ -1,5 +1,6 @@
-import rx
-import rx.operators as ops
+import reactivex as rx
+from reactivex import operators as ops
+
 
 numbers = rx.from_([1, 2, 3])
 pub_numbers = numbers.pipe(ops.publish())

Chapter04/range1.py

@@ -1,4 +1,4 @@
-import rx
+import reactivex as rx
 
 
 numbers = rx.range(1, 4)

Chapter04/range2.py

@@ -1,4 +1,4 @@
-import rx
+import reactivex as rx
 
 numbers = rx.from_(range(1, 5))
 numbers.subscribe(

Chapter04/range3.py

@@ -1,4 +1,4 @@
-import rx
+import reactivex as rx
 
 numbers = rx.from_(range(1, 10, 2))
 numbers.subscribe(

Chapter04/repeat1.py

@@ -1,5 +1,5 @@
-import rx
-import rx.operators as ops
+import reactivex as rx
+from reactivex import operators as ops
 
 ones = rx.just(1).pipe(ops.repeat(5))
 ones.subscribe(

Chapter04/repeat2.py

@@ -1,5 +1,5 @@
-import rx
-import rx.operators as ops
+import reactivex as rx
+from reactivex import operators as ops
 
 numbers = rx.from_([1, 2, 3])
 numbers.pipe(

Chapter04/retry.py

@@ -1,5 +1,5 @@
-import rx
-import rx.operators as ops
+import reactivex as rx
+from reactivex import operators as ops
 
 
 subscribe_count = 0

Chapter04/start1.py

@@ -1,4 +1,4 @@
-import rx
+import reactivex as rx
 import threading
 
 

Chapter04/start2.py

@@ -1,5 +1,5 @@
-import rx
-from rx.scheduler.eventloop import AsyncIOScheduler
+import reactivex as rx
+from reactivex.scheduler.eventloop import AsyncIOScheduler
 import threading
 import asyncio
 
@@ -9,7 +9,7 @@ def foo():
     return 2
 
 
-loop = asyncio.get_event_loop()
+loop = asyncio.new_event_loop()
 done = loop.create_future()
 scheduler = AsyncIOScheduler(loop=loop)
 

Chapter04/subscribe1.py

@@ -1,5 +1,5 @@
-import rx
-from rx.core import Observer
+import reactivex as rx
+from reactivex import Observer
 
 
 class MyObserver(Observer):

Chapter04/subscribe2.py

@@ -1,4 +1,4 @@
-import rx
+import reactivex as rx
 
 
 numbers = rx.from_([1, 2, 3])

Chapter04/throw1.py

@@ -1,4 +1,4 @@
-import rx
+import reactivex as rx
 
 error = rx.throw("Something wrong happened")
 error.subscribe(

Chapter04/throw2.py

@@ -1,4 +1,4 @@
-import rx
+import reactivex as rx
 
 exception = rx.throw(NotImplementedError("I do nothing"))
 exception.subscribe(

Chapter04/timer1.py

@@ -1,9 +1,9 @@
-from rx import Observable
+import reactivex as rx
 import datetime
 import time
 
 print("starting at {}".format(datetime.datetime.now()))
-one_shot = Observable.timer(1000)
+one_shot = rx.timer(1.0)
 one_shot.subscribe(
         on_next=lambda i: print("tick {} at {}".format(
             i, datetime.datetime.now())),

Chapter05/asyncio_scheduler1.py

@@ -1,11 +1,11 @@
-import rx
-import rx.operators as ops
-from rx.scheduler.eventloop import AsyncIOScheduler
+import reactivex as rx
+import reactivex.operators as ops
+from reactivex.scheduler.eventloop import AsyncIOScheduler
 import threading
 import asyncio
 import threading
 
-loop = asyncio.get_event_loop()
+loop = asyncio.new_event_loop()
 asyncio_scheduler = AsyncIOScheduler(loop=loop)
 numbers = rx.from_([1, 2, 3, 4], scheduler=asyncio_scheduler)
 

Chapter05/newthread_scheduler1.py

@@ -1,6 +1,6 @@
-import rx
-import rx.operators as ops
-from rx.scheduler import NewThreadScheduler
+import reactivex as rx
+import reactivex.operators as ops
+from reactivex.scheduler import NewThreadScheduler
 import threading
 import time
 

Chapter05/newthread_scheduler2.py

@@ -1,6 +1,6 @@
-import rx
-import rx.operators as ops
-from rx.scheduler import NewThreadScheduler
+import reactivex as rx
+import reactivex.operators as ops
+from reactivex.scheduler import NewThreadScheduler
 import threading
 import time
 

Chapter05/threadpool_scheduler1.py

@@ -1,6 +1,6 @@
-import rx
-import rx.operators as ops
-from rx.scheduler import ThreadPoolScheduler
+import reactivex as rx
+import reactivex.operators as ops
+from reactivex.scheduler import ThreadPoolScheduler
 import threading
 import time
 

Chapter05/threadpool_scheduler2.py

@@ -1,6 +1,6 @@
-import rx
-import rx.operators as ops
-from rx.scheduler import ThreadPoolScheduler
+import reactivex as rx
+import reactivex.operators as ops
+from reactivex.scheduler import ThreadPoolScheduler
 import threading
 import time
 

Chapter06/audio-encode-server/LICENSE.txt

@@ -0,0 +1,21 @@
+MIT License
+
+Copyright (c) 2023, Romain Picard
+
+Permission is hereby granted, free of charge, to any person obtaining a copy
+of this software and associated documentation files (the "Software"), to deal
+in the Software without restriction, including without limitation the rights
+to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+copies of the Software, and to permit persons to whom the Software is
+furnished to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in all
+copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+SOFTWARE.

Chapter06/audio-encode-server/README.rst

@@ -1,6 +1,6 @@
 import os
 from collections import namedtuple
-import rx
+import reactivex as rx
 import sox
 
 from cyclotron import Component