Skip to content

Latest commit

 

History

History
39 lines (28 loc) · 746 Bytes

README.md

File metadata and controls

39 lines (28 loc) · 746 Bytes
Raw

zmq.d

A higher level, idiomatic zmq wrapper for the D language.

Features

  • wrappers for common zmq methods
  • resource management and destruction
  • policy based concurrency support
  • vibe.d support ( integration with vibe.d event loop )
/// default concurrency - as is, blocking
import dzmq;
auto ctx = new ZmqContext();
auto sock = ctx.socket!(ZmqSocketType.Req)();
sock.connect("tcp://localhost:1234")
/// vibe.d concurrency - fibers ,yields execution while waiting
import dzmq;
import dzmq.concurrency_mixins;

auto ctx = new ZmqContext();
auto sock = ctx.socket!(ZmqSocketType.Req, VibeDConcurrencyPolicy)();
sock.connect("tcp://localhost:1234");

TBD

  • Callbacks on messages
  • Threading support