Age | Commit message (Collapse) | Author |
|
♻️ (connection_details.rs): refactor `new` method to return Result for better error handling
✨ (connection_details.rs): set default adapter set to "DEFAULT" if none provided
✨ (ls_client.rs): update `new` method to handle Result from ConnectionDetails::new
🐛 (main.rs): fix subscription item list to include correct items
♻️ (main.rs): replace magic number with constant for max connection attempts
|
|
♻️ (ls_client.rs): streamline WebSocket 'wsok' message sending code
|
|
🔧 Update .gitignore to exclude .vscode directory
✨ Add futures-util and url dependencies to Cargo.toml
♻️ Refactor error handling into separate error module in Rust project
💡 Add get_password method documentation in connection_details.rs
♻️ Replace String with Transport enum for forced_transport in connection_options.rs
✨ Implement WebSocket connection logic in ls_client.rs with async support
✨ Add ClientStatus, ConnectionType, and DisconnectionType enums to manage client states in ls_client.rs
✨ (main.rs): add Transport enum to LightstreamerClient imports for WebSocket support
♻️ (main.rs): refactor signal handling to use SharedState struct for clean shutdown
✨ (main.rs): implement AtomicBool for graceful disconnect handling
📝 (main.rs): update comments to reflect new signal handling logic
✨ (main.rs): set forced transport to WebSocket streaming in Lightstreamer client options
✨ (util.rs): create new util module with clean_message function for message sanitization
|
|
♻️ (client_listener.rs): make ClientListener trait Send to allow cross-thread usage
✨ (main.rs): implement signal handling for graceful shutdown
♻️ (main.rs): refactor client creation to use Arc<Mutex> for shared state
♻️ (main.rs): add retry logic for persistent connection attempts
♻️ (subscription_listener.rs): make SubscriptionListener trait Send to allow cross-thread usage
|
|
|
|
'GPL-3.0-only' for better SPDX compliance
|
|
|