- use new ntex's timer api
- v3: Boxed Packet::Connect to trim down Packet size
- v5: Boxed Packet::Connect and Packet::ConnAck variants to trim down Packet size
- v3/v5: Fixed nested with_queues calls in sink impl
-
v3/v5: PublishBuilder::send_at_least_once initiates publish synchronously
-
v3/v5: Publish::take_payload() replaces payload with empty bytes, returns existing
- v3: avoid nested borrow_mut() calls in sink on puback mismatch
- Re-export ClientRouter, SubscribeBuilder, UnsubscribeBuilder
- v3: Remove special treatment for "?" in publish's topic
- Upgrade to ntex-0.4
- Use
Handshake<Io>
instead ofcodec::Connect
for selector
- Add coonditional mqtt server selector
-
Process unhandled data on disconnect #51
-
Fix for panic while parsing MQTT version #52
-
v5: Fix reason string encoding
-
v5: Allow to set reason and properties to SUBACK
-
v5: Add a
packet()
function toSubscribe
andUnsubscribe
-
upgrade ntex, drop direct futures dependency
HandshakeAck::buffer_params()
replaces individual methods for buffer sizes
- Allow to override io buffer params
- Cleanup dependencies
- Upgrade to ntex v0.3
- Upgrade to ntex v0.2
- Upgrade to ntex v0.2-b.7
- Use ntex v0.2-b.5 framed types
- v5: Flush io stream before disconnect
- v5: Restore
set_properties
sink method
- Use ntex 0.2
- v5: Add ping and disconnect support to default control service
- Use pin-project-lite instead of pin-project
-
v5: Check publish service readiness error
-
io: Fix potential BorrowMut error in io dispatcher
- Fix public re-exports
- Fix out of bounds panic
- Better read back-pressure support
-
Use ashash instead on fxhash
-
Drop unneeded InOrder service usage
-
Refactor io dispatcher
-
Rename Connect/ConnectAck to Handshake/HandshakeAck
- v5: Allow to configure ConnectAck::max_qos value
-
Do not print publish payload in debug fmt
-
v5: Create topic handlers on firse use
- v5: Handle "Request Problem Information" flag
- v3: Fix borrow error in sink impl
- Allow to set packet id for sink operations
-
v5: Add helper method Connect::fail_with()
-
v5: Better name SubscribeIter::confirm()
- v5: Fix borrow error in MqttSink::close_with_reason()
- Add async fn
MqttSink::ready()
returns when there is available client credit.
-
ControlMessage
(v3/v5) and referenced types have#[derive(Debug)]
added -
Add
Deref
impl forSession<_>
-
v5: Do not override
max_packet_size
,receive_max
andtopic_alias_max
-
Fix packet ordering
-
Check default router service readiness
-
v5: Fix in/out bound frame size checks in codec
-
v5: Add PublishBuilder::set_properties() helper method
-
v3: Fix PublishBuilder methods
- v5: Add Error::ack_with() helper method
-
v3: New client api
-
v5: New client api
-
v5: Send publish packet returns ack or publish error
-
v5: set
max_qos
toAtLeastOnce
for serverConnectAck
response -
v5: do not set
session_expiry_interval_secs
prop
- v5: do not convert publish error to ack for QoS0 packets
-
v5: Handle packet id in use for publish, subscribe and unsubscribe packets
-
v5: Handle 16 concurrent control service requests
-
v3: Handle packet id in use for subscribe and unsubscribe packets
-
v3: Handle 16 concurrent control service requests
-
Removed ProtocolError::DuplicatedPacketId error
- v5: Fix max inflight check
-
v5: Add topic aliases support
-
v5: Forward publish errors to control service
-
Move keep-alive timeout to Framed dispatcher
-
Rename PublishBuilder::at_most_once/at_least_once into send_at_most_once/send_at_least_once
-
Replace ConnectAck::properties with ConnectAck::with
- Fix v5 decoding for properties going beyond properties boundary
-
Fix v5 server constraints
-
Add v3::Connect::service_unavailable()
-
Refactor Topics matching
- Add Publish::packet_mut() method
-
Add mqtt v5 protocol support
-
Refactor control packets handling
- Check for duplicated in-flight packet ids
- Update ntex
- Add disconnect timeout
- For to ntex namespace
- Add server handshake timeout
- Fix server keep-alive impl
- Allow to specify multi-pattern for topics
-
Migrate to
std::future
-
Support publish with QoS 1
- Initial release