Huge News!Announcing our $40M Series B led by Abstract Ventures.Learn More
Socket
Sign inDemoInstall
Socket

@most/core

Package Overview
Dependencies
Maintainers
4
Versions
47
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

@most/core - npm Package Compare versions

Comparing version 1.3.5 to 1.4.0

type-definitions/combinator/variadic.d.ts

2

package.json
{
"name": "@most/core",
"version": "1.3.5",
"version": "1.4.0",
"description": "Reactive programming with lean, functions-only, curried, tree-shakeable API",

@@ -5,0 +5,0 @@ "typings": "type-definitions/most.d.ts",

import { Stream } from '@most/types';
import { ToStreamsArray } from './variadic'

@@ -8,37 +9,3 @@ export function combine<A, B, R>(fn: (a: A, b: B) => R, a: Stream<A>, b: Stream<B>): Stream<R>;

export function combineArray<A, B, R>(
fn: (a: A, b: B) => R,
streams: [Stream<A>, Stream<B>]
): Stream<R>;
export function combineArray<A, B, C, R>(
fn: (a: A, b: B, c: C) => R,
streams: [Stream<A>, Stream<B>, Stream<C>]
): Stream<R>;
export function combineArray<A, B, C, D, R>(
fn: (a: A, b: B, c: C, d: D) => R,
streams: [Stream<A>, Stream<B>, Stream<C>, Stream<D>]
): Stream<R>;
export function combineArray<A, B, C, D, E, R>(
fn: (a: A, b: B, c: C, d: D, e: E) => R,
streams: [Stream<A>, Stream<B>, Stream<C>, Stream<D>, Stream<E>]
): Stream<R>;
export function combineArray<V, R> (
fn: (...items: V[]) => R,
items: Stream<V>[]
): Stream<R>;
export function combineArray<A, B, R>(
fn: (a: A, b: B) => R,):
(streams: [Stream<A>, Stream<B>]) => Stream<R>;
export function combineArray<A, B, C, R>(
fn: (a: A, b: B, c: C) => R):
(streams: [Stream<A>, Stream<B>, Stream<C>]) => Stream<R>;
export function combineArray<A, B, C, D, R>(
fn: (a: A, b: B, c: C, d: D) => R):
(streams: [Stream<A>, Stream<B>, Stream<C>, Stream<D>]) => Stream<R>;
export function combineArray<A, B, C, D, E, R>(
fn: (a: A, b: B, c: C, d: D, e: E) => R):
(streams: [Stream<A>, Stream<B>, Stream<C>, Stream<D>, Stream<E>]) => Stream<R>;
export function combineArray<V, R> (
fn: (...items: V[]) => R):
(items: Stream<V>[]) => Stream<R>;
export function combineArray<Args extends any[], R>(fn: (...args: Args) => R, streams: ToStreamsArray<Args>): Stream<R>;
export function combineArray<Args extends any[], R>(fn: (...args: Args) => R): (streams: ToStreamsArray<Args>) => Stream<R>;

@@ -5,2 +5,7 @@ import { Stream } from '@most/types';

export function merge<A, B>(s1: Stream<A>): (s2: Stream<B>) => Stream<A | B>
export function mergeArray<A>(streams: Array<Stream<A>>): Stream<A>;
// TODO: use readonly Stream<any>[] once TS 3.4.x has been in the wild for "enough" time
type MergeArray<S extends ReadonlyArray<Stream<any>>> = Value<S[number]>
type Value<S> = S extends Stream<infer A> ? A : never
export function mergeArray<S extends ReadonlyArray<Stream<any>>>(streams: S): Stream<MergeArray<S>>;
import { Stream } from '@most/types';
import { ToStreamsArray } from './variadic'

@@ -8,36 +9,3 @@ export function zip<A, B, R>(fn: (a: A, b: B) => R, a: Stream<A>, b: Stream<B>): Stream<R>;

export function zipArray<A, B, R>(
fn: (a: A, b: B) => R,
streams: [Stream<A>, Stream<B>]
): Stream<R>;
export function zipArray<A, B, C, R>(
fn: (a: A, b: B, c: C) => R,
streams: [Stream<A>, Stream<B>, Stream<C>]
): Stream<R>;
export function zipArray<A, B, C, D, R>(
fn: (a: A, b: B, c: C, d: D) => R,
streams: [Stream<A>, Stream<B>, Stream<C>, Stream<D>]
): Stream<R>;
export function zipArray<A, B, C, D, E, R>(
fn: (a: A, b: B, c: C, d: D, e: E) => R,
streams: [Stream<A>, Stream<B>, Stream<C>, Stream<D>, Stream<E>]
): Stream<R>;
export function zipArray<V, R> (
fn: (...items: V[]) => R,
items: Stream<V>[]
): Stream<R>;
export function zipArray<A, B, R>(fn: (a: A, b: B) => R):
(streams: [Stream<A>, Stream<B>]) => Stream<R>;
export function zipArray<A, B, C, R>(fn: (a: A, b: B, c: C)=> R):
(streams: [Stream<A>, Stream<B>, Stream<C>]) => Stream<R>;
export function zipArray<A, B, C, D, R>(fn: (a: A, b: B, c: C, d: D) => R):
(streams: [Stream<A>, Stream<B>, Stream<C>, Stream<D>]) => Stream<R>;
export function zipArray<A, B, C, D, E, R>(fn: (a: A, b: B, c: C, d: D, e: E) => R):
(streams: [Stream<A>, Stream<B>, Stream<C>, Stream<D>, Stream<E>]) => Stream<R>;
export function zipArray<V, R> (fn: (...items: V[]) => R):
(items: Stream<V>[]) => Stream<R>;
export function zipArray<Args extends any[], R>(fn: (...args: Args) => R, streams: ToStreamsArray<Args>): Stream<R>;
export function zipArray<Args extends any[], R>(fn: (...args: Args) => R): (streams: ToStreamsArray<Args>) => Stream<R>;

Sorry, the diff of this file is not supported yet

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

Packages

npm

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc