import {from} from 'rxjs';
import {conduit} from '@rxtk/socketio';

const messageIn$ = from([
  {topic: 'message', body: 'yarrr'},
  {topic: 'message', body: 'arrr matey'},
  {topic: 'message', body: 'Vitamin C? Never heard of it.'},
  {topic: 'message', body: 'Why is all the rum gone?'},
]);

const socketConfig = {
  url: 'http://localhost:9080/ws', // socket.io server
  topics: ['message'], // topics to subscribe to. (Defaults to ['message']).
  // the socket options get passed directly to the Socket.io instance, allowing
  // any customization that the socket.io client supports.
  socketOptions: {
    transports: ['websocket'],
    auth: {token: 'secretjwttoken'},
  },
}; 
// the conduit operator sends messages from messageIn$ and emits messages 
// from the server
const messageBack$ = messageIn$.pipe(conduit({...socketConfig}));
messageBack$.subscribe(console.log);
messageBack$.error$.subscribe(console.error); // optional: handle errors
// {topic: 'message', body: 'Welcome Matey.'}
// {topic: 'message', body: 'Yo ho. Yo ho. I am a message from the server.'}

import {from} from 'rxjs';
import {conduit} from '@rxtk/socketio';

const messageIn$ = from([
  {topic: 'next-audio-chunk', index: 0, binary: Buffer.from('foobar', 'base64')},
  {topic: 'next-audio-chunk', index: 1, binary: Buffer.from('foobar', 'base64')},
]);
const socketConfig = {
  url: 'http://localhost:9080/ws',
  topics: ['message', 'audio-received'],
};
messageIn$.pipe(conduit({...socketConfig}));
// {topic: 'audio-received', index: 0}
// {topic: 'audio-received', index: 1}