vue3 composable for NATS

• connects to NATS using a websocket
• publish/subscribe to subjects
• reactive

Setup App.vue

1import { createNats } from '@c0d3x42/vue3-nats'
2import { createApp } from 'vue';
3import App from 'App.vue';
4
5createApp(App).use(createNats({servers: ['ws://localhost:8443']}));

Components

Publishing

1import { publish } from '@c0d3x42/vue3-nats';
2import { StringCodec } from 'nats.ws';
3const sc = StringCodec();
4publish("some.subject", sc.encode("hello from vue3"));

Subscribing

1import { subscribe } from '@c0d3x42/vue3-nats';
2
3const { msg } = subscribe("some.subject");
4watch(msg, (m) => {
5  console.log("msg received", m.data)
6})

Request/Response

1import { request } from '@c0d3x42/vue3-nats';
2import { StringCodec } from 'nats.ws';
3const sc = StringCodec();
4
5request("req.res.subject", sc.encode("some payload"))
6.then(msg => {
7  console.log("response was", msg.data);
8})
9