fix ReaderObservable.chainTaskK and add chainObservableK

docs/modules/ReaderObservable.ts.md

@@ -36,10 +36,12 @@ Added in v0.6.6
   - [apSecond](#apsecond)
   - [chainFirst](#chainfirst)
   - [chainIOK](#chainiok)
+  - [chainObservableK](#chainobservablek)
   - [chainTaskK](#chaintaskk)
   - [flatten](#flatten)
   - [fromIOK](#fromiok)
   - [fromObservableK](#fromobservablek)
+  - [fromTaskK](#fromtaskk)
   - [local](#local)
 - [constructors](#constructors)
   - [ask](#ask)
@@ -309,13 +311,25 @@ export declare const chainIOK: <A, B>(f: (a: A) => IO<B>) => <R>(ma: ReaderObser
 
 Added in v0.6.6
 
+## chainObservableK
+
+**Signature**
+
+```ts
+export declare const chainObservableK: <A, B>(
+  f: (a: A) => Observable<B>
+) => <R>(ma: ReaderObservable<R, A>) => ReaderObservable<R, B>
+```
+
+Added in v0.6.6
+
 ## chainTaskK
 
 **Signature**
 
 ```ts
 export declare const chainTaskK: <A, B>(
-  f: (a: A) => Observable<B>
+  f: (a: A) => Task<B>
 ) => <R>(ma: ReaderObservable<R, A>) => ReaderObservable<R, B>
 ```
 
@@ -355,6 +369,18 @@ export declare const fromObservableK: <A extends unknown[], B>(
 
 Added in v0.6.6
 
+## fromTaskK
+
+**Signature**
+
+```ts
+export declare const fromTaskK: <A extends unknown[], B>(
+  f: (...a: A) => Task<B>
+) => <R>(...a: A) => ReaderObservable<R, B>
+```
+
+Added in v0.6.6
+
 ## local
 
 **Signature**

src/ReaderObservable.ts

@@ -11,6 +11,7 @@ import { Filterable2 } from 'fp-ts/lib/Filterable'
 import { flow, identity, Predicate, Refinement } from 'fp-ts/lib/function'
 import { Functor2 } from 'fp-ts/lib/Functor'
 import { IO } from 'fp-ts/lib/IO'
+import { Task } from 'fp-ts/lib/Task'
 import { Monad2 } from 'fp-ts/lib/Monad'
 import { MonadIO2 } from 'fp-ts/lib/MonadIO'
 import { MonadTask2 } from 'fp-ts/lib/MonadTask'
@@ -128,10 +129,25 @@ export const fromObservableK = <A extends Array<unknown>, B>(
  * @category combinators
  * @since 0.6.6
  */
-export const chainTaskK = <A, B>(
+export const chainObservableK = <A, B>(
   f: (a: A) => Observable<B>
 ): (<R>(ma: ReaderObservable<R, A>) => ReaderObservable<R, B>) => chain(a => fromObservableK(f)(a))
 
+/**
+ * @category combinators
+ * @since 0.6.6
+ */
+export const fromTaskK = <A extends Array<unknown>, B>(
+  f: (...a: A) => Task<B>
+): (<R>(...a: A) => ReaderObservable<R, B>) => (...a) => fromTask(f(...a))
+
+/**
+ * @category combinators
+ * @since 0.6.6
+ */
+export const chainTaskK = <A, B>(f: (a: A) => Task<B>): (<R>(ma: ReaderObservable<R, A>) => ReaderObservable<R, B>) =>
+  chain(a => fromTaskK(f)(a))
+
 // -------------------------------------------------------------------------------------
 // type class members
 // -------------------------------------------------------------------------------------

test/ReaderObservable.ts

@@ -305,8 +305,14 @@ describe('ReaderObservable', () => {
     assert.deepStrictEqual(x, 1)
   })
 
-  it('chainTaskK', async () => {
+  it('chainObservableK', async () => {
     const f = (s: string) => R.of(s.length)
+    const x = await _.run(pipe(_.of('a'), _.chainObservableK(f)), undefined)
+    assert.deepStrictEqual(x, 1)
+  })
+
+  it('chainTaskK', async () => {
+    const f = (s: string) => T.of(s.length)
     const x = await _.run(pipe(_.of('a'), _.chainTaskK(f)), undefined)
     assert.deepStrictEqual(x, 1)
   })