mysql-query-observable

function that creates Rx observable from query

Usage no npm install needed!

<script type="module">
  import mysqlQueryObservable from 'https://cdn.skypack.dev/mysql-query-observable';
</script>

README

mysql-query-observable

Creates Rx observable from query

Uses pooling
Requires pgsql environment variables to be set

Example

$ npm install --save mysql-query-observable

import {createObservableFromQuery} from 'mysql-query-observable'

createObservableFromQuery(`
  SELECT * FROM item ORDER BY id ASC LIMIT 2
`)
.toArray()
.subscribe(data => console.log(data)) // [{item1}, {item2}]