- Introducing
sea-streamer-file
: the File Backend
- Added
File
, OpenOptions
, AsyncReadExt
etc to sea-streamer-runtime
- Added
AsyncMutex
to sea-streamer-runtime
- Added
OwnedMessage
to sea-streamer-types
- Added
TIMESTAMP_FORMAT
and SEA_STREAMER_INTERNAL
to sea-streamer-types
- Implemented
serde::Serialize
for MessageHeader
Breaking changes
- Removed const
SEA_STREAMER_INTERNAL
from sea-streamer-redis
StreamUrl
now requires an ending slash to avoid ambiguity, StreamerUri
remains unchanged
assert!("redis://localhost/a,b".parse::<StreamUrl>().is_ok());
assert!("redis://localhost/".parse::<StreamUrl>().is_ok());
assert!("redis://localhost".parse::<StreamUrl>().is_err()); // previously this was OK
assert!("redis://localhost".parse::<StreamerUri>().is_ok());