Module swim.io.mqtt
module swim.io.mqtt
MQTT socket modem for concurrently transporting explicitly flow-controlled
MQTT streams over a network without blocking or intermediate buffering.
-
Packages
PackageDescriptionMQTT socket modem for concurrently transporting explicitly flow-controlled MQTT streams over a network without blocking or intermediate buffering. -
Modules
ModifierModuleDescriptiontransitiveIncremental I/O; functional parsers and writers; display, debug, and diagnostic formatters; and Unicode and binary codecs.transitiveExplicitly flow-controlled, non-blocking, parallel I/O engine, with swim-codec-modulated socket modems, and TCP and TLS transports.transitiveMQTT packet model and wire protocol codec that incrementally decodes and encodes MQTT streams without intermediate buffering.ModifierModuleDescriptiontransitiveImmutable, structure sharing collections, including hash array mapped tries, finger tries, B-trees, and S-trees (sequence trees).transitiveTimer, task, and continuation passing style interfaces, with lightweight scheduler and execution stage implementations.transitiveGeneric structured data model, with support for selectors, expressions, and lambda functions.