fix(io): update typings for IO.from()

src/main/IO.ts

@@ -16,6 +16,7 @@ import {Race} from '../operators/Race'
 import {OR, Zip} from '../operators/Zip'
 import {Computation} from '../sources/Computation'
 import {Timeout} from '../sources/Timeout'
+import {AnyEnv} from '../envs/AnyEnv'
 
 const NOOP = () => {}
 const RETURN_NOOP = () => NOOP
@@ -117,14 +118,9 @@ export class IO<R1, A1> implements FIO<R1, A1> {
    * In most cases you should use [encase] [encaseP] etc. to create new IOs.
    * `from` is for more advanced usages and is intended to be used internally.
    */
-  public static from<A>(
-    cmp: (
-      env: SchedulerEnv,
-      rej: REJ,
-      res: RES<A>,
-      sh: IScheduler
-    ) => Cancel | void
-  ): IO<SchedulerEnv, A> {
+  public static from<R = AnyEnv, A = never>(
+    cmp: (env: R, rej: REJ, res: RES<A>, sh: IScheduler) => Cancel | void
+  ): IO<R, A> {
     return IO.to(new Computation(cmp))
   }
 

test/Once.test.ts

@@ -43,7 +43,7 @@ describe('OnceCache', () => {
   const createRejectingOnceIO = (n: number) => {
     let count = 0
     const io = new Once(
-      IO.from<never>((env, rej, res, sh) =>
+      IO.from((env, rej, res, sh) =>
         sh.delay(() => rej(new Error('FAILED_' + (count += 1).toString())), n)
       )
     )

test/Race.test.ts

@@ -42,15 +42,15 @@ describe('race', () => {
   })
   it('should cancel the second io on resolution of one', async () => {
     let cancelled = 0
-    const a = IO.from<never>(() => () => (cancelled = cancelled + 1))
+    const a = IO.from(() => () => (cancelled = cancelled + 1))
     const b = IO.of(100)
     const result = await a.race(b).toPromise({scheduler: testScheduler()})
     assert.equal(result, 100)
     assert.equal(cancelled, 1)
   })
   it('should cancel the second io on rejection of one', async () => {
     let cancelled = 0
-    const a = IO.from<never>(() => () => (cancelled = cancelled + 1))
+    const a = IO.from(() => () => (cancelled = cancelled + 1))
     const b = IO.reject(new Error('YO'))
     const message = await a
       .race(b)

test/Zip.test.ts

@@ -30,7 +30,7 @@ describe('zip', () => {
 
   it('should cancel the second io if one of them is rejected', async () => {
     let cancelled = 0
-    const a = IO.from<never>(() => () => (cancelled = cancelled + 1))
+    const a = IO.from(() => () => (cancelled = cancelled + 1))
     const b = IO.reject(new Error('Waka'))
     const err = await a
       .zip(b)
@@ -42,7 +42,7 @@ describe('zip', () => {
 
   it('should cancel the second io if one of them is rejected (TEST_SCHEDULER)', async () => {
     let cancelled = 0
-    const a = IO.from<never>(() => () => (cancelled = cancelled + 1))
+    const a = IO.from(() => () => (cancelled = cancelled + 1))
     const b = IO.from((env, rej, res, sh) =>
       sh.delay(() => rej(new Error('Save Me!')), 100)
     )