All files / src/impl CompletableFactory.impl.ts

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
 
 
 
 
12x
12x
 
 
 
 
 
 
12x
267x
 
 
 
 
 
 
 
111x
111x
111x
111x
 
 
 
267x
 
 
 
267x
267x
 
 
267x
 
import { CompletableFactory } from "@jonloucks/concurrency-ts/api/CompletableFactory";
import { Completable, Config as CompletableConfig} from "@jonloucks/concurrency-ts/api/Completable";
import { Config as ConcurrencyConfig, Contracts } from "@jonloucks/concurrency-ts/api/Concurrency";
 
import { create as createCompletableImpl } from "./Completable.impl";
import { Internal } from "./Internal.impl";
 
/** 
 * Create a new CompletableFactory
 *
 * @return the new CompletableFactory
 */
export function create(config?: ConcurrencyConfig): CompletableFactory {
  return CompletableFactoryImpl.internalCreate(config);
}
 
// ---- Implementation details below ----
 
class CompletableFactoryImpl implements CompletableFactory {
  
  createCompletable<T>(config?: CompletableConfig<T>): Completable<T> {
    const validConfig = config ?? {};
    const contracts: Contracts = Internal.resolveContracts(validConfig, this.#concurrencyConfig);
    const finalConfig: ConcurrencyConfig = { ...this.#concurrencyConfig, ...validConfig, contracts: contracts };
    return createCompletableImpl<T>(finalConfig)
  }
 
  static internalCreate(config?: ConcurrencyConfig): CompletableFactory {
    return new CompletableFactoryImpl(config);
  }
 
  private constructor(config?: ConcurrencyConfig) {
    const contracts: Contracts = Internal.resolveContracts(config);
    this.#concurrencyConfig = { ...config, contracts: contracts };
  }
  
  readonly #concurrencyConfig: ConcurrencyConfig;
};