nats_dart library

Classes

BidirectionalMessage
Client
ClientOptions
ConnectEvent
ConnectionEvent
ConnectMessage
ConnectMessageProto
DataMessage
DataMessageProto
DisconnectEvent
Enum
ErrorMessage
ErrorMessageProto
Event
Events
IncomingMessage
InfoMessage
InfoMessageProto
log
Message<E extends MessageProto>
MessageEvent
MessageFactory
allows dependency injection via our ioc container
MessageProto
MessageProtoFactory
NonMessageEvent
OkMessage
OkMessageProto
OutgoingMessage
PayloadMessage
PayloadMessageProto
PingMessage
PingMessageProto
PongMessage
PongMessageProto
PresenceMessage
ProtocolHandler
ProtocolHandlerFactory
ProtocolParser
ProtocolParserFactory
PubMessage
allows dependency injection via our ioc container
PubMessageProto
ReconnectEvent
RequestEvent
RequestSubscription
Server
ServerOptions
ServersChangedEvent
ServerSet
SubMessage
SubMessageProto
SubscribeEvent
Subscription
SubscriptionEvent
SubscriptionFactory
SubscriptionList
UnsubMessage
UnsubMessageProto
UnsubscribeEvent

Mixins

EventEmitter
EventSubscriber

Constants

DEFAULT_CONNECT_TIMEOUT → const Duration
const Duration(seconds: 10)
DEFAULT_HOST → const String
'localhost'
DEFAULT_PORT → const int
4222
VERSION → const String
'0.0.1'

Properties

container ↔ KiwiContainer
read / write

Functions

asNonBroadcastStream<T>(Stream<T> stream) → Stream<T>
ifBlank(String test, String dfault) → String
ifEmpty(String test, String dfault) → String
interleave<T>(Iterable<Stream<T>> streams) → Stream<T>
printEvent(Event event, {int color}) → void

Enums

MessageType
PayloadType

Typedefs

MessageHandler(DataMessage message, {NatsError error}) → void

Exceptions / Errors

NatsError