dartzmq 1.0.0-dev.4
dartzmq: ^1.0.0-dev.4 copied to clipboard
A simple dart zeromq implementation/wrapper around the libzmq C++ library
1.0.0-dev.4 #
Fix heap corruption due to wrong usage of malloc.allocate #
- Use periodic timer to poll sockets every second
- Poll all messages on socket instead of one for each event to not loose messages
- Reuse zeromq message pointer
- Improve return code handling
- Rename
_isActiveofZContextto_shutdown - Rename
_handleand_zmqofZSocketto_socketand_context - Add stream for
ZFramestoZSocket - Always show error code in
ZeroMQException - Fix pubspec of example
1.0.0-dev.3 #
Add example, subscriptions for sub sockets and code cleanup #
- Add minimal working example
- Rename
ZmqSockettoZSocket - Rename
ZeroMQtoZContext - Rename
ZeroMQBindingstorZMQBindings - Add
subscribe(String topic)andunsubscribe(String topic)to manage subscriptions ofsubsockets
1.0.0-dev.2 #
Add support for multipart messages #
- Rename
MessagetoZFrame - Add
ZMessageas a queue ofZFrame's - Receive messages as
ZMessageinstead ofMessage(ZFrame) - Reduce minimum SDK version to
2.13.0
1.0.0-dev.1 #
Add crude implementation of libzmq #
- Creating sockets (pair, pub, sub, req, rep, dealer, router, pull, push, xPub, xSub, stream)
- Sending messages (of type
List<int>) - Bind (
bind(String address)) - Connect (
connect(String address)) - Curve (
setCurvePublicKey(String key),setCurveSecretKey(String key)andsetCurveServerKey(String key)) - Socket options (
setOption(int option, String value))