{ "info": { "author": "Anton P. Linevich", "author_email": "anton@linevich.com", "bugtrack_url": null, "classifiers": [], "description": "=========\nRexPython\n=========\n\nThis is Reactive Extensions (Rx) for Python implementation mimicing RxJava2 API as far as it can.\nIt is LINQ free btw. The goal to make it hackable on the go.\n\nhttps://github.com/chexov/rexpython\n\n\nInstallation\n============\npip install rexpython\n\n=====\nUsage\n=====\nimport rexpython as rx\n\ndef on_subscribe(emitter):\n emitter.setDisposable(ActionDisposable(lambda: sys.stdout.write(\"disposed\")))\n\n print (\"subscribed\")\n for i in xrange(1, 3):\n emitter.onNext(i)\n time.sleep(1)\n\n # emitter.onError(Exception(\"foo\"))\n emitter.onComplete()\n\nframes = rx.Observable.create(lambda emitter: on_subscribe(emitter, video_url, 2))\nmat_img = frames.map(featureextractor.FeatureExtractor.preprocess_image)\nvect = mat_img.map(lambda img: fe.get_activations([img]))\nwords = vect.map(lambda vec: d.getWordsForBatch(vec, 40)) \\\n .flatMap(lambda wlist: rx.Observable.from_(wlist))\nwords = words.doOnNext(lambda w: log.info(\"words=%s\" % w)).doOnError(lambda err: log.error(\"ERRRORRR %s\" % err))\nvalue = words.toList().blockingGet()", "description_content_type": null, "docs_url": null, "download_url": "", "downloads": { "last_day": -1, "last_month": -1, "last_week": -1 }, "home_page": "http://pypi.python.org/pypi/rexpython/", "keywords": "rx rxpy rxjava reactive", "license": "LICENSE.txt", "maintainer": "", "maintainer_email": "", "name": "rexpython", "package_url": "https://pypi.org/project/rexpython/", "platform": "", "project_url": "https://pypi.org/project/rexpython/", "project_urls": { "Homepage": "http://pypi.python.org/pypi/rexpython/" }, "release_url": "https://pypi.org/project/rexpython/0.1.9/", "requires_dist": null, "requires_python": "", "summary": "Simple Reactive Extensions (Rx) for Python", "version": "0.1.9" }, "last_serial": 3068264, "releases": { "0.1.0": [ { "comment_text": "", "digests": { "md5": "d5908e299dad1ede9be6e21d4335f2bd", "sha256": "1c2c7a03e4dc271163525b48f7666cf5136f82479c7bedb86970bb399c070016" }, "downloads": -1, "filename": "rexpython-0.1.0.tar.gz", "has_sig": false, "md5_digest": "d5908e299dad1ede9be6e21d4335f2bd", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 5174, "upload_time": "2017-06-19T23:07:26", "url": "https://files.pythonhosted.org/packages/7b/8e/5583562c11e242ec057e0936db45239b3eb2932a5b178b188482250f2c21/rexpython-0.1.0.tar.gz" } ], "0.1.1": [ { "comment_text": "", "digests": { "md5": "5b155755e12d79a3f162eb3783cb199d", "sha256": "f1a2b35c915de7298e51691ede876108ff5c1a1eef2cd937b02beb7caf0b8991" }, "downloads": -1, "filename": "rexpython-0.1.1.tar.gz", "has_sig": false, "md5_digest": "5b155755e12d79a3f162eb3783cb199d", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 5210, "upload_time": "2017-06-19T23:08:51", "url": "https://files.pythonhosted.org/packages/08/34/7c6cef8c8c734c4de45e9d7be05afdd4a765cc1fc9b5f04a3bea053306db/rexpython-0.1.1.tar.gz" } ], "0.1.2": [ { "comment_text": "", "digests": { "md5": "7dfef900b8e9e624a8ba3a3aec9b63da", "sha256": "c2861e9cde57c5022e9cffa7882b28b526dae405747831939e21f7644e55074a" }, "downloads": -1, "filename": "rexpython-0.1.2.tar.gz", "has_sig": false, "md5_digest": "7dfef900b8e9e624a8ba3a3aec9b63da", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 4822, "upload_time": "2017-06-19T23:29:47", "url": "https://files.pythonhosted.org/packages/be/a2/4a3833c589c6821371fe9806fa444a3bef570c018a49f23bca44412325ac/rexpython-0.1.2.tar.gz" } ], "0.1.4": [ { "comment_text": "", "digests": { "md5": "102544823397ad0ac4e75f390150bc85", "sha256": "6df5a8e7720fcb7b1b84803d1ad037ab538b102db12468e46d1d49a97bbb3da8" }, "downloads": -1, "filename": "rexpython-0.1.4.tar.gz", "has_sig": false, "md5_digest": "102544823397ad0ac4e75f390150bc85", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 5587, "upload_time": "2017-06-21T01:18:14", "url": "https://files.pythonhosted.org/packages/bf/d1/e685caf58f54789986a03bdd0704844e3c3056e3c234df6c0d9da4747440/rexpython-0.1.4.tar.gz" } ], "0.1.5": [ { "comment_text": "", "digests": { "md5": "445e590424196a2dd8746f6f7c71c365", "sha256": "74d7f48c73d229b0239579f10383c9e950511a2458832d76023947426ec466c7" }, "downloads": -1, "filename": "rexpython-0.1.5.tar.gz", "has_sig": false, "md5_digest": "445e590424196a2dd8746f6f7c71c365", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 5593, "upload_time": "2017-06-21T01:21:11", "url": "https://files.pythonhosted.org/packages/d4/1a/92806be0620200270d61db1bc3ac80a2803a8200294619c62178be7b3e5a/rexpython-0.1.5.tar.gz" } ], "0.1.6": [ { "comment_text": "", "digests": { "md5": "5ab4dbc5f908a1849333cc1af6b9e05d", "sha256": "3a491073b21bb2e6b7235bfa945d0c58e6b3a5b2fcdfffbb6ff94bb61f4ac3a3" }, "downloads": -1, "filename": "rexpython-0.1.6.tar.gz", "has_sig": false, "md5_digest": "5ab4dbc5f908a1849333cc1af6b9e05d", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 7004, "upload_time": "2017-06-21T23:27:37", "url": "https://files.pythonhosted.org/packages/b7/32/3ca313146541659ce144f2a5d796cf5d54d9f2395f25a68dafd77b2fbf45/rexpython-0.1.6.tar.gz" } ], "0.1.7": [ { "comment_text": "", "digests": { "md5": "405a5e26e69e205564142d6fc21001b8", "sha256": "3e74a7e1b30549a1c6144773bb0cd554e12ffd456a2cb25f4ae71576fbd985b4" }, "downloads": -1, "filename": "rexpython-0.1.7.tar.gz", "has_sig": false, "md5_digest": "405a5e26e69e205564142d6fc21001b8", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 7017, "upload_time": "2017-07-05T22:15:59", "url": "https://files.pythonhosted.org/packages/22/f3/ced886bbd91e4e2eeed129e9857eb31ad9f45a14f6e3750237e3648315fb/rexpython-0.1.7.tar.gz" } ], "0.1.8": [ { "comment_text": "", "digests": { "md5": "0432444be79820d8a3253fb39f856b71", "sha256": "cb2d7c70895c46b690fee9f717f2eeaa8bf1fc00fe558eaca077a115b9ca7d7c" }, "downloads": -1, "filename": "rexpython-0.1.8.tar.gz", "has_sig": false, "md5_digest": "0432444be79820d8a3253fb39f856b71", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 7506, "upload_time": "2017-07-05T22:59:43", "url": "https://files.pythonhosted.org/packages/80/df/c9e2919377f7c94bd7ad7eb0bf315f0a4d21f96bcbeaabc83f3d1b527658/rexpython-0.1.8.tar.gz" } ], "0.1.9": [ { "comment_text": "", "digests": { "md5": "b5f8e5a8ca74c390fea42cc73bb55136", "sha256": "2a822270b70af5843708cee522887297763a38ebd24e09f4dd2b859311abda66" }, "downloads": -1, "filename": "rexpython-0.1.9.tar.gz", "has_sig": false, "md5_digest": "b5f8e5a8ca74c390fea42cc73bb55136", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 7523, "upload_time": "2017-08-02T21:12:01", "url": "https://files.pythonhosted.org/packages/1d/9b/3ac8c46a0d5e4525b848255c331593145701debcb8df6eb619ffaa9bcee6/rexpython-0.1.9.tar.gz" } ] }, "urls": [ { "comment_text": "", "digests": { "md5": "b5f8e5a8ca74c390fea42cc73bb55136", "sha256": "2a822270b70af5843708cee522887297763a38ebd24e09f4dd2b859311abda66" }, "downloads": -1, "filename": "rexpython-0.1.9.tar.gz", "has_sig": false, "md5_digest": "b5f8e5a8ca74c390fea42cc73bb55136", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 7523, "upload_time": "2017-08-02T21:12:01", "url": "https://files.pythonhosted.org/packages/1d/9b/3ac8c46a0d5e4525b848255c331593145701debcb8df6eb619ffaa9bcee6/rexpython-0.1.9.tar.gz" } ] }