MQTT socket modem for concurrently transporting explicitly flow-controlled MQTT streams over a network without blocking or intermediate buffering.
Exports Package Description swim.io.mqttMQTT socket modem for concurrently transporting explicitly flow-controlled MQTT streams over a network without blocking or intermediate buffering.
Requires Modifier Module Description transitive swim.codecIncremental I/O; functional parsers and writers; display, debug, and diagnostic formatters; and Unicode and binary codecs. transitive swim.ioExplicitly flow-controlled, non-blocking, parallel I/O engine, with swim-codec-modulated socket modems, and TCP and TLS transports. transitive swim.mqttMQTT packet model and wire protocol codec that incrementally decodes and encodes MQTT streams without intermediate buffering. Indirect Requires Modifier Module Description transitive swim.collectionsImmutable, structure sharing collections, including hash array mapped tries, finger tries, B-trees, and S-trees (sequence trees). transitive swim.concurrentTimer, task, and continuation passing style interfaces, with lightweight scheduler and execution stage implementations. transitive swim.structureGeneric structured data model, with support for selectors, expressions, and lambda functions.