rsocket

View on PyPIReverse Dependencies (0)

0.4.19 rsocket-0.4.19-py3-none-any.whl

Wheel Details

Project: rsocket
Version: 0.4.19
Filename: rsocket-0.4.19-py3-none-any.whl
Download: [link]
Size: 91658
MD5: c8a96b134968d357e908555273d8bc3c
SHA256: 77551551d87a2163ad6b78cf26f6e1a93f5e510d28add0da28443fff9a24f46c
Uploaded: 2025-04-13 12:09:25 +0000

dist-info

METADATA

Metadata-Version: 2.4
Name: rsocket
Version: 0.4.19
Summary: Python RSocket library
Author: Gabriel Shaar
Author-Email: workofishi[at]pm.me
Home-Page: https://github.com/rsocket/rsocket-py
License: MIT
Classifier: Development Status :: 4 - Beta
Classifier: Programming Language :: Python
Classifier: Programming Language :: Python :: 3.8
Classifier: Programming Language :: Python :: 3.9
Classifier: Programming Language :: Python :: 3.10
Classifier: Programming Language :: Python :: 3.11
Classifier: Programming Language :: Python :: 3.12
Classifier: Programming Language :: Python :: 3.13
Classifier: Environment :: Web Environment
Classifier: License :: OSI Approved :: MIT License
Classifier: Natural Language :: English
Classifier: Topic :: Internet :: WWW/HTTP :: Dynamic Content
Classifier: Topic :: Internet :: WWW/HTTP
Classifier: Topic :: Internet
Classifier: Topic :: Software Development :: Libraries :: Application Frameworks
Classifier: Topic :: Software Development :: Libraries :: Python Modules
Requires-Python: >=3.8
Requires-Dist: Rx (>=3.0.0); extra == "rx"
Requires-Dist: reactivex (>=4.0.0); extra == "reactivex"
Requires-Dist: aiohttp (>=3.0.0); extra == "aiohttp"
Requires-Dist: quart (>=0.15.0); extra == "quart"
Requires-Dist: aioquic (>=0.9.0); extra == "quic"
Requires-Dist: asyncclick (>=8.0.0); extra == "cli"
Requires-Dist: cbitstruct (>=1.1.0); extra == "optimized"
Requires-Dist: fastapi (>=0.115.0); extra == "fastapi"
Requires-Dist: cloudevents (>=1.9.0); extra == "cloudevents"
Requires-Dist: pydantic (>=1.10.0); extra == "cloudevents"
Requires-Dist: graphql-core (>=3.2.0); extra == "graphql"
Requires-Dist: gql (>=3.4.0); extra == "graphql"
Requires-Dist: websockets (>=11.0.0); extra == "websockets"
Requires-Dist: channels (>=4.0.0); extra == "channels"
Requires-Dist: daphne (>=4.1.2); extra == "channels"
Requires-Dist: asyncwebsockets (>=0.9.4); extra == "asyncwebsockets"
Provides-Extra: rx
Provides-Extra: reactivex
Provides-Extra: aiohttp
Provides-Extra: quart
Provides-Extra: quic
Provides-Extra: cli
Provides-Extra: optimized
Provides-Extra: fastapi
Provides-Extra: cloudevents
Provides-Extra: graphql
Provides-Extra: websockets
Provides-Extra: channels
Provides-Extra: asyncwebsockets
Description-Content-Type: text/markdown
Dynamic: license-file
License-File: LICENSE
[Description omitted; length: 6999 characters]

WHEEL

Wheel-Version: 1.0
Generator: setuptools (78.1.0)
Root-Is-Purelib: true
Tag: py3-none-any

RECORD

Path Digest Size
reactivestreams/__init__.py sha256=7VJYIuCgxT5mwxWmVcEKaUleAIixhV31HrYYNBqP83I 172
reactivestreams/publisher.py sha256=7st20Y6tvXvhwVhdK7FFIA2iqnxCxDms6GSg6l30t-o 381
reactivestreams/subscriber.py sha256=KnTrUxLflqIccF2tbeF_aLAyvjm7kruWep_k_YAIB8Q 1447
reactivestreams/subscription.py sha256=uhZq0jeYAz65giPL5hZ9OL1Z6tST4Ef6GM87iVfw2jw 372
rsocket/__init__.py sha256=5Q2XwR4eMAaYk7enJisRMwDgxbbB9bTvxLfqxXYP9cM 23
rsocket/async_helpers.py sha256=7_Mlht2Ls_ukgLkxy0-T1od5pWdi3hMfDQ0ZUvJD1W0 126
rsocket/datetime_helpers.py sha256=CN6Hyc7AMtgxa8c3M93QZufWUMJrds3sYH46hK9UOvY 164
rsocket/disposable.py sha256=KBF_dvc_zsqMQ3yv0RiN-haTamLeMNEwwMx7-NOB03s 114
rsocket/error_codes.py sha256=ZKYMp6-PDPpsgEUUZ_IiMWuQfmZwexgd3kVYRLRQcSo 375
rsocket/exceptions.py sha256=j1QseL59CvQa25yw5iXNG6LIEoXkXPxv6c3XxNOpRuE 1894
rsocket/fragment.py sha256=bJqEfsmJA3Nvc2wSGqZr8zUkwzLBKVrLAHvGwBLhdFE 595
rsocket/frame.py sha256=CRo6s5v9jRkUIifMXLCC4QIK-uUjKMiC6YxYHLuJnVM 26267
rsocket/frame_builders.py sha256=u-g3JRMP48Vo_PqXutt5lcWgJGADl97fu6MVYjSNcMQ 4293
rsocket/frame_fragment_cache.py sha256=HjaDD6cjupQcjDWXBnET_9aVtOsZ3M9RnoCRHyYMh1o 2483
rsocket/frame_fragmenter.py sha256=ETgMmtNVf6nI99ow6Lt9t8b_zCWPAs3cKr0tUcDy2e4 4261
rsocket/frame_helpers.py sha256=evsM1mnOR7PXS0mNlDfd5JWq2jkQSNDy516I2hTL_lY 2851
rsocket/frame_logger.py sha256=vIlpwKJc-tZVBDqlKN8N0GgwKUIN2m1BrB_RPEiTPbo 4557
rsocket/frame_parser.py sha256=WQdM0YiL-nG5QgmrB9EHsssHeC527qlRtVTQK4wQL6E 1261
rsocket/helpers.py sha256=KXVYtZr-XpxMYousWvgeP2CH862QsyCLAQGn3aUJGX0 4045
rsocket/lease.py sha256=4Pzg-FHbzwNGDQ6iJ3Rn1lkbOs3w2a6Fic9JFQumnpM 3087
rsocket/local_typing.py sha256=lu8gO9nMPUDqBRGtz6DZlkuoRuf9tBRnuEpag5MNwZE 315
rsocket/logger.py sha256=6GQLxSuRc1_M5U0Ad270js1QPGAs8LOzhJV6N26yP2A 73
rsocket/payload.py sha256=OZ0Zjz6W9nzS6Cm_Q_HnNwmVcfWL2x3FTdptuYYh7sw 858
rsocket/queue_peekable.py sha256=ils1bWiM7MK_kuiOHpX5r0NCUJ7ixWKPUVRlGEsNLf4 1628
rsocket/request_handler.py sha256=g1OLqf21Fo_zw2stbj-PaECePwFtoMuP_Hmm_IjD-n8 4557
rsocket/rsocket.py sha256=8AFLn38Reaj7rehUsm5IXksj5XnaNbLSDlWZlc2HEQA 1284
rsocket/rsocket_base.py sha256=rIPar_xjpQivub0GEXsjk8_LyLU9ZpU1Yy-bjtQceZ8 22417
rsocket/rsocket_client.py sha256=kZuvZ_ZyLl4OsMO-T9oHIOswu8GEZO_XphWj-ZbnLP0 7963
rsocket/rsocket_internal.py sha256=T54TexsJGxIuiE6OXvn7q7Gy_NQ7nzm8tyD_2un5vTg 971
rsocket/rsocket_server.py sha256=KZsRr9Z8zM6qI-cCkS4DaOLyCl9XkW6f42L7UnooS9g 2959
rsocket/stream_control.py sha256=1JdnYEGKeTb_k-Obe9Apfd7rtCxtn6qf9NuVRr1DU8s 2709
rsocket/awaitable/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
rsocket/awaitable/awaitable_rsocket.py sha256=qOG9HfC-AXfe_jOFmkLatq1Ak9NZOa1-ucVAKA56fN0 2108
rsocket/awaitable/collector_subscriber.py sha256=dOod7-qD9WVPcPjv4g-P-eC7nUURTY4NSYTjg8lBNWM 1672
rsocket/cli/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
rsocket/cli/command.py sha256=zTAYWZKfd4lnEclOiNDeiN-8YnblyGEhFfKKIRg9P5U 14189
rsocket/cloudevents/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
rsocket/cloudevents/serialize.py sha256=CZ4xL80jgJ-K4Hvtd3cTz1UBlW9aYhreTVLV9a1XLFU 457
rsocket/extensions/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
rsocket/extensions/authentication.py sha256=vT469WO5V1W_b89JoSysN4FVITX8dBsTFjQHipKyzHQ 2192
rsocket/extensions/authentication_content.py sha256=C9WZpkM01JOrG5swodVgxCRE-yWvY2UfSNrLXPGRLbw 1594
rsocket/extensions/authentication_types.py sha256=rEfg6TDxtAGjwlSbcifrZ-w4lXoWoTxE3QaLjIhe4R8 945
rsocket/extensions/composite_metadata.py sha256=E7FVOqy5GUs9hmtra-uySmfZnqpUc3QjY3Mf9iL1-aQ 3364
rsocket/extensions/composite_metadata_item.py sha256=bBKpkaZxuOUatusw74Zgv5KsHDK6xg3ZzKyy-fHJot4 995
rsocket/extensions/helpers.py sha256=YHQoRfHvM3j6Um6aAgUG9mgrqKnIDxGAocES2MDDO7k 1752
rsocket/extensions/mimetype.py sha256=qhHFUyMDIuDz4bN3bhXD6PppgMZJRD09CyBfIC1geGc 380
rsocket/extensions/mimetypes.py sha256=j-ngNpfdHa_jjW9VTHG0qH2NmlfGD4tyjz87oLmY7_U 4755
rsocket/extensions/routing.py sha256=3horHf_W3ce_qSusSHVGvwmJN1NedFPuvIsN0y6w5x4 358
rsocket/extensions/stream_data_mimetype.py sha256=MnnxTjIWt3hWNu3DKH3IQyi44Td_OwNztLbJidL0t8w 2336
rsocket/extensions/tagging.py sha256=U9bjdAzx9DiE_WHTsXLYWeJo_HQtRjkGVBoD333DRe0 1460
rsocket/graphql/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
rsocket/graphql/rsocket_transport.py sha256=qEbqOlPM8ZhsGtZ6HWOQjnVFSQrb4TlwpbgD11Cou3Y 4576
rsocket/graphql/server_helper.py sha256=v1OpR-MZwRHjEJn6fC0pDsq5pc9fVtjKYPHMS3IlbLw 3101
rsocket/handlers/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
rsocket/handlers/interfaces.py sha256=Y6KVJWl6-07ms4vFc-vdMeTFdJAVhuUt6KkneU66Nl8 167
rsocket/handlers/request_cahnnel_common.py sha256=6L_dfTxrvsA-vQb-64sCmLsNHPdS2ZBseVpXfAD_MLE 4598
rsocket/handlers/request_cahnnel_responder.py sha256=a_GvQeWhFCHZOFk6yWDFuo-HvgrvuC5tL1vp7xl8I04 807
rsocket/handlers/request_channel_requester.py sha256=iZpShy6rgygDGgwtz-KGN12s6IeTBeWOy5CdAnU8C6E 1526
rsocket/handlers/request_response_requester.py sha256=RHdYQBRaTNFnA_A7edvxE-IunQI1LsopRqD9fPb7ddQ 1602
rsocket/handlers/request_response_responder.py sha256=_2EQJIuETgLGOb_i7QsMkjUWEGcAhgfDP11BFZSStl0 1018
rsocket/handlers/request_stream_requester.py sha256=xEupFSe81EI0cyaA8Byb9k0slma309rOgOcV0bHSVKk 1866
rsocket/handlers/request_stream_responder.py sha256=7BXhhQkd8YwYTcXfjGpJ285IINPdAzf8-kGJCq-iRNs 2151
rsocket/load_balancer/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
rsocket/load_balancer/load_balancer_rsocket.py sha256=nWEklX7_djmYFOUqVdvaKYN1uZPsybWSh7EvefaI528 1771
rsocket/load_balancer/load_balancer_strategy.py sha256=2lQ_uDtDwvbXOazKKLfdqKBhxvMcjdk634hTkPqP6gQ 362
rsocket/load_balancer/random_client.py sha256=RU1kpPa4Bf7z089WLL47h7gHd1sRmbo-Cbv6OvnE4nE 956
rsocket/load_balancer/round_robin.py sha256=YTMoc3vAtmf2Ez3AF7D7y6I9RCePgHEHFjy8Uk-skbg 1017
rsocket/reactivex/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
rsocket/reactivex/back_pressure_publisher.py sha256=1F2k_u2uk99_GjBYC3itinQ32MP-LgZkJZrt2tLp_J0 6920
rsocket/reactivex/from_rsocket_publisher.py sha256=88qHprux3MM7SVvIyliQdp3p--VRMrOh7oFO6V6jrsY 3758
rsocket/reactivex/reactivex_channel.py sha256=J9yvzlZnJbsD0E-iwAzIHELXN2KAfeoBJ9dHO5b-8yg 383
rsocket/reactivex/reactivex_client.py sha256=Sy3JWv4ak6s0b_3EVEaJdTztuS0j6hgLXJehTeRq5bo 2343
rsocket/reactivex/reactivex_handler.py sha256=HXI_S4R-gKpF_PSM-amyRv7p_FEDamKWCX08Jv1LX3s 3785
rsocket/reactivex/reactivex_handler_adapter.py sha256=urcQZB1ZAEtlf-0PdE6co31wSzf78oruU6Ry94f1d54 3069
rsocket/reactivex/subscriber_adapter.py sha256=84zFSMa1zo6zX0bJM4JWKIVwzr7n79DgUy6ib4E93cU 429
rsocket/routing/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
rsocket/routing/request_router.py sha256=BvQ0U0dzyUy7_B5KLOt_5w8w4ckg6mUFdS9WcEfcWBk 6623
rsocket/routing/routing_request_handler.py sha256=RqsSNMCAkydhTrfWo9db4v_U39LhQ7aR09qvGgPt08o 4776
rsocket/rx_support/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
rsocket/rx_support/back_pressure_publisher.py sha256=hOk7qd-hYUeg5q2Q2IHA3Jyq8rRTROqjn2YRydAR7N8 6704
rsocket/rx_support/from_rsocket_publisher.py sha256=ietiE8k5g1pCHPP1YRwozEWsRbE0JTnxje_UonFcOU0 3749
rsocket/rx_support/rx_channel.py sha256=Xr6ZxWJUJHn6d10PdqEu_4UqUP6uJ_IeCRQM1ZurHrM 381
rsocket/rx_support/rx_handler.py sha256=kcPNPVedb_dNFQAPru7-S1QHi3xx2-51ZeQvqNfS8AM 3825
rsocket/rx_support/rx_handler_adapter.py sha256=EmHdeUyzGbKTrwr23RvLomLqLYjbbCPV-gjcni0qTTI 2873
rsocket/rx_support/rx_rsocket.py sha256=aVuZBJHHc_MqflgxmiUWV9KLI0UdjM9TDjvJweYrbXM 2346
rsocket/rx_support/subscriber_adapter.py sha256=wU0IYL9O_46W5LI5V3i4l0kfV-yLgEpK63v_Zy9SgFw 422
rsocket/streams/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
rsocket/streams/backpressureapi.py sha256=wUDhlRZOwdY8rWxdRpFuHR4jp2k0w01ucCRLuMgegGQ 136
rsocket/streams/empty_stream.py sha256=SItL4p-_CtgV4ZvRJILsBapXMgV3XKVSQT8kZzvIzBE 178
rsocket/streams/error_stream.py sha256=-hN85FXcTZYskBuuHd3y2G19mTTJBLkSe6DzN5jFATs 274
rsocket/streams/exceptions.py sha256=uykAcVohuw821yCI4HDELOpJwBzhvgkN6p4F-y0AsAM 44
rsocket/streams/helpers.py sha256=bIrIj8N7X954tWnMDKQBMeOSvP8_IztQTDzS3V0A4XU 267
rsocket/streams/null_subscrier.py sha256=Fba-ljrEozY2CUwC2ec0y0OAvNp5VoJHKwdetSI2byg 373
rsocket/streams/stream_from_async_generator.py sha256=oAqFvcMK3qnglLI1Zwh541rmaO_y3EW9OGd3VQIoook 1402
rsocket/streams/stream_from_generator.py sha256=5L-Nj5c_X3n0B9A8MYLXf6q3ZPktV-DgITI4FvUn_cA 4610
rsocket/streams/stream_handler.py sha256=O2GO1Oz7U7Dh0F8lBT5UZrFTTtL6YHKaQ-5c59rR5rk 1504
rsocket/transports/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
rsocket/transports/abstract_messaging.py sha256=Nh2INIGZbhsuGxnz715D_-bZ0fOVqnmBzusIh-akIkE 512
rsocket/transports/aiohttp_websocket.py sha256=_Ssqoi23esgIChC96dPilUd4Z_DqjZaUIqj7pDzOMEo 4356
rsocket/transports/aioquic_transport.py sha256=oGGNWWEKv6ash8cFBkYfty2PK8nfIw3FI_bKoTVXHWE 4529
rsocket/transports/asyncwebsockets_transport.py sha256=lpDqlVrVhUSvb8v38-YdrW8UfodQshso1YWnWwP6jLs 2232
rsocket/transports/channels_transport.py sha256=Dt9jyTpQeLphSek5io_FTj8CJFcehW9LtpX35XqLtWg 5002
rsocket/transports/http3_transport.py sha256=014_cRCNbnB93Q-dsOuaNfQsCb0qlwFRGiG0T1lJj9U 7823
rsocket/transports/quart_websocket.py sha256=AtE9wHvVt91KAV8i2_ySuqtQDoo_38C0S2v9HKBQxi8 1632
rsocket/transports/tcp.py sha256=yUMjdpg6iW6ksp-5r4FmXcXcvr4eKG-I6VqgjX9LUmE 1650
rsocket/transports/transport.py sha256=LoZIKCyiGqnDRcHVI_lRKFOiJAUGnrsnlNL4nL0Bv2M 1278
rsocket/transports/websockets_transport.py sha256=94EyMa0r6_uBLp9WeuS7HegNU0AiHtQKyb0Bw1ugByo 1267
rsocket-0.4.19.dist-info/licenses/LICENSE sha256=a_QkoWrh4yRzL4CVzPz0la7EnGdeLmZ_TiEMbiB_tsg 1070
rsocket-0.4.19.dist-info/METADATA sha256=9Pa-SeNwmuRp1QJlHEMeabMrjXSUG8EaenIcIADz9XM 9269
rsocket-0.4.19.dist-info/WHEEL sha256=CmyFI0kx5cdEMTLiONQRbGQwjIoR1aIYB7eCAQ4KPJ0 91
rsocket-0.4.19.dist-info/entry_points.txt sha256=9feuVNNBSjS6vLhAEEZWnaUKhmIN2N6NpZ2ZSz0-HgQ 63
rsocket-0.4.19.dist-info/top_level.txt sha256=sap0RkCUc0L_XukU_H10B5MRRTVqUsi3ujhRHlTfTvY 24
rsocket-0.4.19.dist-info/RECORD

top_level.txt

reactivestreams
rsocket

entry_points.txt

rsocket-py = rsocket.cli.command:command