import {createEvent} from 'effector'

const send = createEvent() // unnamed event

const onMessage = createEvent('message') // named event

​

const socket = new WebSocket('wss://echo.websocket.org')

socket.onmessage = msg => onMessage(msg)

socket.onopen = () => send('{"text": "hello"}')

​

const onMessageParse = onMessage.map(msg => JSON.parse(msg.data))

​

onMessageParse.watch(data => {

  console.log('Message from server ', data)

})

​

send.watch(data => {

  socket.send(data)

})

​

​