@@ -207,18 +207,18 @@ <h1>Source code for unicorn_binance_websocket_api.manager</h1><div class="highli
207
207
<span class="kn">from</span> <span class="nn">typing_extensions</span> <span class="kn">import</span> <span class="n">Literal</span>
208
208
209
209
<span class="n">__app_name__</span><span class="p">:</span> <span class="nb">str</span> <span class="o">=</span> <span class="s2">"unicorn-binance-websocket-api"</span>
210
- <span class="n">__version__</span><span class="p">:</span> <span class="nb">str</span> <span class="o">=</span> <span class="s2">"2.7.0"</span>
211
-
212
- <span class="n">logger</span> <span class="o">=</span> <span class="n">logging</span><span class="o">.</span><span class="n">getLogger</span><span class="p">(</span><span class="s2">"unicorn_binance_websocket_api"</span><span class="p">) </span>
210
+ <span class="n">__version__</span><span class="p">:</span> <span class="nb">str</span> <span class="o">=</span> <span class="s2">"2.7.0.dev "</span>
211
+ <span class="n">__logger__</span><span class="p">:</span> <span class="n">logging</span><span class="o">.</span><span class="n">getLogger</span> <span class="o">=</span> <span class="n">logging</span><span class="o">.</span><span class="n">getLogger</span><span class="p">(</span><span class="s2">"unicorn_binance_websocket_api"</span><span class="p">)</span>
212
+ <span class="n">logger</span> <span class="o">=</span> <span class="n">__logger__ </span>
213
213
214
214
215
215
<div class="viewcode-block" id="BinanceWebSocketApiManager">
216
216
<a class="viewcode-back" href="../../unicorn_binance_websocket_api.html#unicorn_binance_websocket_api.manager.BinanceWebSocketApiManager">[docs]</a>
217
217
<span class="k">class</span> <span class="nc">BinanceWebSocketApiManager</span><span class="p">(</span><span class="n">threading</span><span class="o">.</span><span class="n">Thread</span><span class="p">):</span>
218
218
<span class="w"> </span><span class="sd">"""</span>
219
- <span class="sd"> An unofficial Python API to use the Binance Websocket API`s (com+testnet, com-margin+testnet,</span>
220
- <span class="sd"> com-isolated_margin+testnet, com-futures+testnet, us, dex/chain+testnet) in an easy , fast, flexible ,</span>
221
- <span class="sd"> robust and fully-featured way.</span>
219
+ <span class="sd"> A Python SDK by LUCIT to use the Binance Websocket API`s (com+testnet, com-margin+testnet,</span>
220
+ <span class="sd"> com-isolated_margin+testnet, com-futures+testnet, com-coin_futures, us, tr, dex/chain+testnet) in a simple , fast,</span>
221
+ <span class="sd"> flexible, robust and fully-featured way.</span>
222
222
223
223
<span class="sd"> This library supports two different kind of websocket endpoints:</span>
224
224
@@ -5127,12 +5127,13 @@ <h1>Source code for unicorn_binance_websocket_api.manager</h1><div class="highli
5127
5127
<span class="k">if</span> <span class="bp">self</span><span class="o">.</span><span class="n">stream_list</span><span class="p">[</span><span class="n">stream_id</span><span class="p">][</span><span class="s1">'subscriptions'</span><span class="p">]</span> <span class="o">></span> <span class="bp">self</span><span class="o">.</span><span class="n">max_subscriptions_per_stream</span><span class="p">:</span>
5128
5128
<span class="n">error_msg</span> <span class="o">=</span> <span class="p">(</span><span class="sa">f</span><span class="s2">"The limit of </span><span class="si">{</span><span class="nb">str</span><span class="p">(</span><span class="bp">self</span><span class="o">.</span><span class="n">max_subscriptions_per_stream</span><span class="p">)</span><span class="si">}</span><span class="s2"> subscriptions per stream has been "</span>
5129
5129
<span class="sa">f</span><span class="s2">"exceeded!"</span><span class="p">)</span>
5130
- <span class="n">logger</span><span class="o">.</span><span class="n">error</span><span class="p">(</span><span class="sa">f</span><span class="s2">"BinanceWebSocketApiManager.subscribe_to_stream(</span><span class="si">{</span><span class="nb">str</span><span class="p">(</span><span class="n">stream_id</span><span class="p">)</span><span class="si">}</span><span class="s2">) - error_msg: </span><span class="si">{</span><span class="nb">str</span><span class="p">(</span><span class="n">error_msg</span><span class="p">)</span><span class="si">}</span><span class="s2"> "</span><span class="p">) </span>
5131
- <span class="c1"># self._crash_stream(stream_id, error_msg= error_msg)</span>
5132
- <span class="c1">#return False </span>
5133
- <span class="k">raise</span> <span class="n">MaximumSubscriptionsExceeded</span><span class="p">(</ span><span class="n">max_subscriptions </span><span class="o">=</span><span class="nb">str</span><span class="p">(</span><span class=" bp">self</span><span class="o">.</span><span class="n">max_subscriptions_per_stream</span><span class="p">) )</span>
5130
+ <span class="n">logger</span><span class="o">.</span><span class="n">error</span><span class="p">(</span><span class="sa">f</span><span class="s2">"BinanceWebSocketApiManager.subscribe_to_stream(</span><span class="si">{</span><span class="nb">str</span><span class="p">(</span><span class="n">stream_id</span><span class="p">)</span><span class="si">}</span><span class="s2">) - error_msg: "</span>
5131
+ <span class="sa">f</span><span class="s2">"</span><span class="si">{</span><span class="nb">str</span><span class="p">(</span><span class="n"> error_msg</span><span class="p">)</span><span class="si">}</span><span class="s2">"</span><span class="p"> )</span>
5132
+ <span class="k">raise</span> <span class="n">MaximumSubscriptionsExceeded</span><span class="p">(</span><span class="n">exchange</span><span class="o">=</span><span class="bp">self</span><span class="o">.</span><span class="n">get_exchange</span><span class="p">(), </span>
5133
+ < span class="n">max_subscriptions_per_stream </span><span class="o">=</span><span class="bp">self</span><span class="o">.</span><span class="n">max_subscriptions_per_stream</span><span class="p">)</span>
5134
5134
<span class="k">if</span> <span class="n">payload</span> <span class="ow">is</span> <span class="kc">None</span><span class="p">:</span>
5135
- <span class="n">logger</span><span class="o">.</span><span class="n">error</span><span class="p">(</span><span class="sa">f</span><span class="s2">"BinanceWebSocketApiManager.subscribe_to_stream(</span><span class="si">{</span><span class="nb">str</span><span class="p">(</span><span class="n">stream_id</span><span class="p">)</span><span class="si">}</span><span class="s2">) - error_msg: Payload is None!"</span><span class="p">)</span>
5135
+ <span class="n">logger</span><span class="o">.</span><span class="n">error</span><span class="p">(</span><span class="sa">f</span><span class="s2">"BinanceWebSocketApiManager.subscribe_to_stream(</span><span class="si">{</span><span class="nb">str</span><span class="p">(</span><span class="n">stream_id</span><span class="p">)</span><span class="si">}</span><span class="s2">) - error_msg: Payload is "</span>
5136
+ <span class="sa">f</span><span class="s2">"None!"</span><span class="p">)</span>
5136
5137
<span class="k">return</span> <span class="kc">False</span>
5137
5138
<span class="k">try</span><span class="p">:</span>
5138
5139
<span class="k">for</span> <span class="n">item</span> <span class="ow">in</span> <span class="n">payload</span><span class="p">:</span>
@@ -5409,7 +5410,7 @@ <h3>Navigation</h3>
5409
5410
<a href="https://docs.lucit.tech">Index of all LUCIT Software Documentation</a><br />
5410
5411
© <a href="/license.html">Copyright</a> 2023-2023, LUCIT Systems and Development. All Rights Reserved..
5411
5412
See <a href="/license.html">License</a> for more information.<br />
5412
- Last updated on May 11 2024 at 23:32 (CET).
5413
+ Last updated on May 12 2024 at 11:04 (CET).
5413
5414
<a href="https://github.com/LUCIT-Systems-and-Development/unicorn-binance-websocket-api/issues/new/choose">Found a bug</a>?
5414
5415
<br />
5415
5416
Created using <a href="https://www.sphinx-doc.org/">Sphinx</a> 7.2.6.
0 commit comments