File streaming.test.ts

test/streaming.test.ts:None–None

import test from "ava"
import { spawn, Thread, Worker } from "../src/index"

test("can use worker returning an observable subject", async t => {