push version 0.2.9

Author: areed1192

README.md

@@ -15,6 +15,8 @@
 
 ## Overview
 
+Current Version: **0.2.9**
+
 The unofficial Python API client library for TD Ameritrade allows individuals with TD Ameritrade accounts to manage trades, pull historical and real-time data, manage their accounts, create and modify orders all using the Python programming language.
 
 To learn more about the TD Ameritrade API, please refer to the [official documentation](https://developer.tdameritrade.com/apis).
@@ -60,6 +62,12 @@ The project can be found at PyPI, if you'd like to view the project please use t
 pip install td-ameritrade-python-api
 ```
 
+To upgrade the library run the following command:
+
+```bash
+pip install --upgrade td-ameritrade-python-api
+```
+
 ## Usage
 
 This example demonstrates how to login to the API and demonstrates sending a request using the `get_quotes` endpoint, using your API key.

setup.py

@@ -16,7 +16,7 @@
 
     # I'm in alpha development still, so a compliant version number is a1.
     # read this as MAJOR VERSION 0, MINOR VERSION 1, MAINTENANCE VERSION 0
-    version='0.2.8',
+    version='0.2.9',
 
     # here is a simple description of the library, this will appear when
     # someone searches for the library on https://pypi.org/search

td/stream.py

@@ -3,6 +3,7 @@
 import io
 import json
 import os
+import textwrap
 import unicodedata
 import urllib
 
@@ -562,26 +563,34 @@ def close_logic(self, logic_type: str) -> bool:
 
     async def close_stream(self) -> None:
         """Closes the connection to the streaming service."""        
-
-        print('Connection with server closed, beginning close process...')
 
         # close the connection.
         await self.connection.close()
 
+        # Define the Message.
+        message = textwrap.dedent("""
+        {lin_brk}
+        CLOSING PROCESS INITIATED:
+        {lin_brk}
+        WebSocket Closed: True
+        Event Loop Closed: True
+        {lin_brk}
+        """).format(lin_brk="="*80)
+        
         # Shutdown all asynchronus generators.
         await self.loop.shutdown_asyncgens()
 
         # Stop the loop.
         if self.loop.is_running():
             self.loop.call_soon_threadsafe(self.loop.stop())
-        
-        self.loop.close()
+            print(message)
+            await asyncio.sleep(3)
 
-        # Once closed, verify it's closed.
-        if self.loop.is_closed():
-            print('Event loop was closed.')
-        else:            
-            print('Event loop was not closed.')
+        # # Once closed, verify it's closed.
+        # if self.loop.is_closed():
+        #     print('Event loop was closed.')
+        # else:            
+        #     print('Event loop was not closed.')
 
         # # cancel all the task.
         # for index, task in enumerate(asyncio.Task.all_tasks()):
@@ -706,7 +715,7 @@ async def _receive_message(self, return_value: bool = False) -> dict:
                 elif self.print_to_console:
                     print('='*20)
                     print('Message Received:')
-                    print('')
+                    print('-'*20)
                     print(message_decoded)
                     print('-'*20)
                     print('')         
@@ -715,7 +724,7 @@ async def _receive_message(self, return_value: bool = False) -> dict:
 
                 # stop the connection if there is an error.
                 await self.close_stream()
-                break               
+                break           
 
     async def _parse_json_message(self, message: str) -> dict:
         """Parses incoming messages from the stream