* feat: Replace mplex with yamux as default multiplexer in py-libp2p
* Retain Mplex alongside Yamux in new_swarm with messaging that Yamux is preferred
* moved !BBHII to a constant YAMUX_HEADER_FORMAT at the top of yamux.py with a comment explaining its structure
* renamed the news fragment to 534.feature.rst and updated the description
* renamed the news fragment to 534.feature.rst and updated the description
* added a docstring to clarify that Yamux does not support deadlines natively
* Remove the __main__ block entirely from test_yamux.py
* Replaced the print statements in test_yamux.py with logging.debug
* Added a comment linking to the spec for clarity
* Raise NotImplementedError in YamuxStream.set_deadline per review
* Add muxed_conn to YamuxStream and test deadline NotImplementedError
* Fix Yamux implementation to meet libp2p spec
* Fix None handling in YamuxStream.read and Yamux.read_stream
* Fix test_connected_peers.py to correctly handle peer connections
* fix: Ensure StreamReset is raised on read after local reset in yamux
* fix: Map MuxedStreamError to StreamClosed in NetStream.write for Yamux
* fix: Raise MuxedStreamReset in Yamux.read_stream for closed streams
* fix: Correct Yamux stream read behavior for NetStream tests
Fixed est_net_stream_read_after_remote_closed by updating NetStream.read to raise StreamEOF when the stream is remotely closed and no data is available, aligning with test expectations and Fixed est_net_stream_read_until_eof by modifying YamuxStream.read to block until the stream is closed (
ecv_closed=True) for
=-1 reads, ensuring data is only returned after remote closure.
* fix: Correct Yamux stream read behavior for NetStream tests
Fixed est_net_stream_read_after_remote_closed by updating NetStream.read to raise StreamEOF when the stream is remotely closed and no data is available, aligning with test expectations and Fixed est_net_stream_read_until_eof by modifying YamuxStream.read to block until the stream is closed (
ecv_closed=True) for
=-1 reads, ensuring data is only returned after remote closure.
* fix: raise StreamEOF when reading from closed stream with empty buffer
* fix: prioritize returning buffered data even after stream reset
* fix: prioritize returning buffered data even after stream reset
* fix: Ensure test_net_stream_read_after_remote_closed_and_reset passes in full suite
* fix: Add __init__.py to yamux module to fix documentation build
* fix: Add __init__.py to yamux module to fix documentation build
* fix: Add libp2p.stream_muxer.yamux to libp2p.stream_muxer.rst toctree
* fix: Correct title underline length in libp2p.stream_muxer.yamux.rst
* fix: Add a = so that is matches the libp2p.stream\_muxer.yamux length
* fix(tests): Resolve race condition in network notification test
* fix: fixing failing tests and examples with yamux and noise
* refactor: remove debug logging and improve x25519 tests
* fix: Add functionality for users to choose between Yamux and Mplex
* fix: increased trio sleep to 0.1 sec for slow environment
* feat: Add test for switching between Yamux and mplex
* refactor: move host fixtures to interop tests
* chore: Update __init__.py removing unused import
removed unused
```python
import os
import logging
```
* lint: fix import order
* fix: Resolve conftest.py conflict by removing trio test support
* fix: Resolve test skipping by keeping trio test support
* Fix: add a newline at end of the file
---------
Co-authored-by: acul71 <luca.pisani@birdo.net>
Co-authored-by: acul71 <34693171+acul71@users.noreply.github.com>
Moved dependencies into Linux, macOS, and Windows sections per Paul's suggestion. Fixed reST formatting (blank lines, title underlines) to resolve Sphinx warnings from ReadTheDocs CI. Tested on Windows 10 (Python 3.11.0).
* Initial setup for pubsup
* Created node and trying to setup gossipsub
* Fix: Use pubsub object for publishing messages instead of gossipsub
* Correct help message for port argument.
* Fix: Used pubsub object instead of gossipsub object on Client side
* Fix: handle_new_peer method of pubsub is used to connect to new peers.
* used for host.connect to connect to peers
* Corrected script for connecting to other peers.
* message receiving function created
* message publishing function created
* Refactored the code for improved clarity and maintainability.
* fix: make publish loop input non-blocking to prevent event loop blocking
* refactored the code for better user experience while publishing message
* corrected the name of protocol
* Fix: Correct the implementation of the port argument
* Added pubsub initialization
* added logging
* pubsub instance is running
* Enhance publish loop with user prompts and error handling
* Connection monitoring added
* Add key pair generation and security options to pubsub host initialization
* Refactor pubsub logging and corrected gossipsub protocol id
* Started gossipsub service
* Add dynamic port assignment
* Refactor pubsub example for CI
* feat: monitor_peer_topics function added
* Noise protocol added
* refactor: default port set to none and some logging changes.
* refactor: Add graceful shutdown with termination events
- Replace infinite loops with termination events
- Add proper shutdown handling for all loops
- Implement clean resource cleanup on exit
- Add shutdown message for better user feedback
- Update signal handling for graceful termination
* Changed import path for factories file.
- to align import statement with changes from PR 543
* Added News Fragment
* Added pub-sub demo to the console_scripts section in setup.py
* Added pubsub example to Documentation
* Fix formatting and path in PubSub documentation example
* Added pubsub example in toctree
* Added tests for pubsub example
* updated the description of pubsub example
* corrected the name of pubsub docs file
* Remove unused imports and security options from pubsub example
* Update script usage instructions in pubsub example
* Enhanced compatibility for python 3.9
* Corrected console output
