dartzmq 1.0.0-dev.6
dartzmq: ^1.0.0-dev.6 copied to clipboard
A simple dart zeromq implementation/wrapper around the libzmq C++ library
1.0.0-dev.6 #
Free pointers before throwing a ZeroMQException #
- Free pointers before throwing a ZeroMQException
- Add return code to
zmq_setsockopt
function - Add return code check to
ZSocket.setOption
function - Add
zmq_has
function for checking supported capabilities - Add helper functions for
zmq_has
1.0.0-dev.5 #
Fix destroying poller and loading shared library #
- Rename
SocketMode
toSocketType
- Add some steps on how to use dartzmq on Android
- Address warnings in bindings.dart
- Fix destroying poller (use **poller instead of *poller)
- Add more class documentation
- Fix loading shared library for orher platforms
- Extend error messages
- Add more socket options
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
_isActive
ofZContext
to_shutdown
- Rename
_handle
and_zmq
ofZSocket
to_socket
and_context
- Add stream for
ZFrames
toZSocket
- 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
ZmqSocket
toZSocket
- Rename
ZeroMQ
toZContext
- Rename
ZeroMQBindings
torZMQBindings
- Add
subscribe(String topic)
andunsubscribe(String topic)
to manage subscriptions ofsub
sockets
1.0.0-dev.2 #
Add support for multipart messages #
- Rename
Message
toZFrame
- Add
ZMessage
as a queue ofZFrame
's - Receive messages as
ZMessage
instead 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)
)