refactor: 💡 rename FunctionStreamingType to FnRxType

Author: streamich

src/type/TypeBuilder.ts

@@ -261,7 +261,7 @@ export class TypeBuilder {
     res: Res,
     options?: schema.Optional<schema.FunctionStreamingSchema>,
   ) {
-    const fn = new classes.FunctionStreamingType<Req, Res, Ctx>(req, res, options);
+    const fn = new classes.FnRxType<Req, Res, Ctx>(req, res, options);
     fn.system = this.system;
     return fn;
   }

src/type/classes.ts

@@ -11,7 +11,7 @@ import {ObjType, ObjectFieldType, ObjectOptionalFieldType} from './classes/ObjTy
 import {MapType} from './classes/MapType';
 import {RefType} from './classes/RefType';
 import {OrType} from './classes/OrType';
-import {FnType, FunctionStreamingType} from './classes/FnType';
+import {FnType, FnRxType} from './classes/FnType';
 
 export {
   AbsType,
@@ -30,5 +30,5 @@ export {
   RefType,
   OrType,
   FnType,
-  FunctionStreamingType,
+  FnRxType,
 };

src/type/classes/FnType.ts

@@ -9,7 +9,7 @@ const fnNotImplemented: schema.FunctionValue<any, any> = async () => {
   throw new Error('NOT_IMPLEMENTED');
 };
 
-const toStringTree = (tab: string = '', type: FnType<Type, Type, any> | FunctionStreamingType<Type, Type, any>) => {
+const toStringTree = (tab: string = '', type: FnType<Type, Type, any> | FnRxType<Type, Type, any>) => {
   return printTree(tab, [
     (tab) => 'req: ' + type.req.toString(tab + '     '),
     (tab) => 'res: ' + type.res.toString(tab + '     '),
@@ -87,7 +87,7 @@ type FunctionStreamingImpl<Req extends Type, Res extends Type, Ctx = unknown> =
   ctx: Ctx,
 ) => Observable<ResolveType<Res>>;
 
-export class FunctionStreamingType<Req extends Type, Res extends Type, Ctx = unknown> extends AbsType<
+export class FnRxType<Req extends Type, Res extends Type, Ctx = unknown> extends AbsType<
   schema.FunctionStreamingSchema<SchemaOf<Req>, SchemaOf<Res>, Ctx>
 > {
   public readonly isStreaming = true;

src/type/types.ts

@@ -21,7 +21,7 @@ export type Type =
   | classes.RefType<any>
   | classes.OrType<any>
   | classes.FnType<any, any, any>
-  | classes.FunctionStreamingType<any, any, any>;
+  | classes.FnRxType<any, any, any>;
 
 export type SchemaOf<T extends Type | Type[]> = T extends BaseType<infer U> ? U : never;
 export type SchemaOfMap<M extends Record<string, Type>> = {
@@ -43,11 +43,11 @@ export type TypeMap = {[name: string]: schema.Schema};
 export type FilterFunctions<T> = {
   [K in keyof T as T[K] extends classes.FnType<any, any, any>
     ? K
-    : T[K] extends classes.FunctionStreamingType<any, any, any>
+    : T[K] extends classes.FnRxType<any, any, any>
       ? K
       : never]: T[K] extends classes.FnType<any, any, any>
     ? T[K]
-    : T[K] extends classes.FunctionStreamingType<any, any, any>
+    : T[K] extends classes.FnRxType<any, any, any>
       ? T[K]
       : never;
 };