import { Renderer } from '../renderer'
import { JSXAsync, JSXElementAsync } from './jsx'
import { jsxAsyncToSync } from './sync'

export const createAsyncRender = <N>(renderer: Renderer<N>) => (jsx: JSXAsync): Observable<N> => {
  const jsxSync$ = jsxAsyncToSync(jsx)
  return new Observable(observer => (
    jsxSync$.subscribe(
      node => observer.next(renderer.renderNode(node)),
      error => observer.error(error),
      () => observer.complete()
    )
  ))
}