combineLatest([o1, o2, o3])
combineLatest({
o1: o1$,
o2: o2$,
})
combineLatest([tank$, keys$, canvasSizes$])
keys$.pipe(
withLatest(tank$),
withLatest(canvasSizes$),
)
workers = []
for lastname in lastnames:
lastname_page = search_host + lastname
lastname_paths = []
paths = threading.Thread(target=recieve_page_html, args=(lastname_page,))
paths.start()
workers.append(paths)
for w in workers:
w.join()
asyncio.run(caller())
При этом обе операции откатятсяЭто rollback и есть. Читайте документацию к используемым библиотекам!