1.0.0 • Published 2 years ago
@rxnode/core v1.0.0
@rxnode/core
observablify
function observablify<A extends Arguments, R extends Results = []>(
fn: (...args: [...A, ErrorCallback<R>]) => any
): (...args: A) => Observable<VoidOrItemOrItems<R>>
watchify
function watchify<A extends Arguments, R extends Results>(
fn: (...args: [...A, Callback<R>]) => any,
{ closeOnUnsubscribe: closeOnUnsubscribe }?: {closeOnUnsubscribe?: boolean;}
): (...args: A) => Observable<VoidOrItemOrItems<R>>