Edit

IPC transport

Purpose

IPC transport for Node as a RxJS Subject.

Installation

npm install @erebos/transport-ipc

Usage

import { createTransport } from '@erebos/transport-ipc'

const transport = createTransport('/path/to/socket')

transport.subcribe({
  next: message => {
    console.log(message)
  },
})
transport.next({ hello: 'transport' })

API

createTransport()

Arguments

1. url: string

Returns Rx.Subject<Object>