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

effect

Package Overview
Dependencies
Maintainers
3
Versions
236
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

effect - npm Package Compare versions

Comparing version 2.0.0-next.19 to 2.0.0-next.20

_mjs/Channel.mjs

270

index.d.ts

@@ -9,2 +9,10 @@ /**

import * as Cause from "effect/Cause";
import * as Channel from "effect/Channel";
import * as ChannelChildExecutorDecision from "effect/ChannelChildExecutorDecision";
import * as ChannelMergeDecision from "effect/ChannelMergeDecision";
import * as ChannelMergeState from "effect/ChannelMergeState";
import * as ChannelMergeStrategy from "effect/ChannelMergeStrategy";
import * as ChannelSingleProducerAsyncInput from "effect/ChannelSingleProducerAsyncInput";
import * as ChannelUpstreamPullRequest from "effect/ChannelUpstreamPullRequest";
import * as ChannelUpstreamPullStrategy from "effect/ChannelUpstreamPullStrategy";
import * as Chunk from "effect/Chunk";

@@ -44,2 +52,3 @@ import * as Clock from "effect/Clock";

import * as Function from "effect/Function";
import * as GroupBy from "effect/GroupBy";
import * as Hash from "effect/Hash";

@@ -56,2 +65,3 @@ import * as HashMap from "effect/HashMap";

import * as LoggerSpan from "effect/LoggerSpan";
import * as Match from "effect/Match";
import * as Metric from "effect/Metric";

@@ -99,10 +109,27 @@ import * as MetricBoundaries from "effect/MetricBoundaries";

import * as ScopedRef from "effect/ScopedRef";
import * as Sink from "effect/Sink";
import * as SortedMap from "effect/SortedMap";
import * as SortedSet from "effect/SortedSet";
import * as STM from "effect/STM";
import * as Stream from "effect/Stream";
import * as StreamEmit from "effect/StreamEmit";
import * as StreamHaltStrategy from "effect/StreamHaltStrategy";
import * as String from "effect/String";
import * as Struct from "effect/Struct";
import * as SubscriptionRef from "effect/SubscriptionRef";
import * as Supervisor from "effect/Supervisor";
import * as Symbol from "effect/Symbol";
import * as SynchronizedRef from "effect/SynchronizedRef";
import * as Take from "effect/Take";
import * as TArray from "effect/TArray";
import * as TDeferred from "effect/TDeferred";
import * as TMap from "effect/TMap";
import * as TPriorityQueue from "effect/TPriorityQueue";
import * as TQueue from "effect/TQueue";
import * as Tracer from "effect/Tracer";
import * as TRandom from "effect/TRandom";
import * as TReentrantLock from "effect/TReentrantLock";
import * as TRef from "effect/TRef";
import * as TSemaphore from "effect/TSemaphore";
import * as TSet from "effect/TSet";
import * as Tuple from "effect/Tuple";

@@ -168,2 +195,74 @@ export {

* ```md
* - Docs: https://effect-ts.github.io/stream/modules/Channel.ts.html
* - Module: "@effect/stream/Channel"
* ```
*/
Channel,
/**
* @since 2.0.0
*
* ```md
* - Docs: https://effect-ts.github.io/stream/modules/Channel/ChildExecutorDecision.ts.html
* - Module: "@effect/stream/Channel/ChildExecutorDecision"
* ```
*/
ChannelChildExecutorDecision,
/**
* @since 2.0.0
*
* ```md
* - Docs: https://effect-ts.github.io/stream/modules/Channel/MergeDecision.ts.html
* - Module: "@effect/stream/Channel/MergeDecision"
* ```
*/
ChannelMergeDecision,
/**
* @since 2.0.0
*
* ```md
* - Docs: https://effect-ts.github.io/stream/modules/Channel/MergeState.ts.html
* - Module: "@effect/stream/Channel/MergeState"
* ```
*/
ChannelMergeState,
/**
* @since 2.0.0
*
* ```md
* - Docs: https://effect-ts.github.io/stream/modules/Channel/MergeStrategy.ts.html
* - Module: "@effect/stream/Channel/MergeStrategy"
* ```
*/
ChannelMergeStrategy,
/**
* @since 2.0.0
*
* ```md
* - Docs: https://effect-ts.github.io/stream/modules/Channel/SingleProducerAsyncInput.ts.html
* - Module: "@effect/stream/Channel/SingleProducerAsyncInput"
* ```
*/
ChannelSingleProducerAsyncInput,
/**
* @since 2.0.0
*
* ```md
* - Docs: https://effect-ts.github.io/stream/modules/Channel/UpstreamPullRequest.ts.html
* - Module: "@effect/stream/Channel/UpstreamPullRequest"
* ```
*/
ChannelUpstreamPullRequest,
/**
* @since 2.0.0
*
* ```md
* - Docs: https://effect-ts.github.io/stream/modules/Channel/UpstreamPullStrategy.ts.html
* - Module: "@effect/stream/Channel/UpstreamPullStrategy"
* ```
*/
ChannelUpstreamPullStrategy,
/**
* @since 2.0.0
*
* ```md
* - Docs: https://effect-ts.github.io/data/modules/Chunk.ts.html

@@ -466,2 +565,11 @@ * - Module: "effect/Chunk"

* ```md
* - Docs: https://effect-ts.github.io/stream/modules/GroupBy.ts.html
* - Module: "@effect/stream/GroupBy"
* ```
*/
GroupBy,
/**
* @since 2.0.0
*
* ```md
* - Docs: https://effect-ts.github.io/data/modules/Hash.ts.html

@@ -584,2 +692,11 @@ * - Module: "effect/Hash"

* ```md
* - Docs: https://effect-ts.github.io/match/modules/index.ts.html
* - Module: "@effect/match"
* ```
*/
Match,
/**
* @since 2.0.0
*
* ```md
* - Docs: https://effect-ts.github.io/io/modules/Metric.ts.html

@@ -972,2 +1089,11 @@ * - Module: "effect/Metric"

* ```md
* - Docs: https://effect-ts.github.io/stream/modules/Sink.ts.html
* - Module: "@effect/stream/Sink"
* ```
*/
Sink,
/**
* @since 2.0.0
*
* ```md
* - Docs: https://effect-ts.github.io/data/modules/SortedMap.ts.html

@@ -991,2 +1117,38 @@ * - Module: "effect/SortedMap"

* ```md
* - Docs: https://effect-ts.github.io/stm/modules/STM.ts.html
* - Module: "@effect/stm/STM"
* ```
*/
STM,
/**
* @since 2.0.0
*
* ```md
* - Docs: https://effect-ts.github.io/stream/modules/Stream.ts.html
* - Module: "@effect/stream/Stream"
* ```
*/
Stream,
/**
* @since 2.0.0
*
* ```md
* - Docs: https://effect-ts.github.io/stream/modules/Stream/Emit.ts.html
* - Module: "@effect/stream/Stream/Emit"
* ```
*/
StreamEmit,
/**
* @since 2.0.0
*
* ```md
* - Docs: https://effect-ts.github.io/stream/modules/Stream/HaltStrategy.ts.html
* - Module: "@effect/stream/Stream/HaltStrategy"
* ```
*/
StreamHaltStrategy,
/**
* @since 2.0.0
*
* ```md
* - Docs: https://effect-ts.github.io/data/modules/String.ts.html

@@ -1010,2 +1172,11 @@ * - Module: "effect/String"

* ```md
* - Docs: https://effect-ts.github.io/stream/modules/SubscriptionRef.ts.html
* - Module: "@effect/stream/SubscriptionRef"
* ```
*/
SubscriptionRef,
/**
* @since 2.0.0
*
* ```md
* - Docs: https://effect-ts.github.io/io/modules/Supervisor.ts.html

@@ -1038,2 +1209,56 @@ * - Module: "effect/Supervisor"

* ```md
* - Docs: https://effect-ts.github.io/stream/modules/Take.ts.html
* - Module: "@effect/stream/Take"
* ```
*/
Take,
/**
* @since 2.0.0
*
* ```md
* - Docs: https://effect-ts.github.io/stm/modules/TArray.ts.html
* - Module: "@effect/stm/TArray"
* ```
*/
TArray,
/**
* @since 2.0.0
*
* ```md
* - Docs: https://effect-ts.github.io/stm/modules/TDeferred.ts.html
* - Module: "@effect/stm/TDeferred"
* ```
*/
TDeferred,
/**
* @since 2.0.0
*
* ```md
* - Docs: https://effect-ts.github.io/stm/modules/TMap.ts.html
* - Module: "@effect/stm/TMap"
* ```
*/
TMap,
/**
* @since 2.0.0
*
* ```md
* - Docs: https://effect-ts.github.io/stm/modules/TPriorityQueue.ts.html
* - Module: "@effect/stm/TPriorityQueue"
* ```
*/
TPriorityQueue,
/**
* @since 2.0.0
*
* ```md
* - Docs: https://effect-ts.github.io/stm/modules/TQueue.ts.html
* - Module: "@effect/stm/TQueue"
* ```
*/
TQueue,
/**
* @since 2.0.0
*
* ```md
* - Docs: https://effect-ts.github.io/io/modules/Tracer.ts.html

@@ -1048,2 +1273,47 @@ * - Module: "effect/Tracer"

* ```md
* - Docs: https://effect-ts.github.io/stm/modules/TRandom.ts.html
* - Module: "@effect/stm/TRandom"
* ```
*/
TRandom,
/**
* @since 2.0.0
*
* ```md
* - Docs: https://effect-ts.github.io/stm/modules/TReentrantLock.ts.html
* - Module: "@effect/stm/TReentrantLock"
* ```
*/
TReentrantLock,
/**
* @since 2.0.0
*
* ```md
* - Docs: https://effect-ts.github.io/stm/modules/TRef.ts.html
* - Module: "@effect/stm/TRef"
* ```
*/
TRef,
/**
* @since 2.0.0
*
* ```md
* - Docs: https://effect-ts.github.io/stm/modules/TSemaphore.ts.html
* - Module: "@effect/stm/TSemaphore"
* ```
*/
TSemaphore,
/**
* @since 2.0.0
*
* ```md
* - Docs: https://effect-ts.github.io/stm/modules/TSet.ts.html
* - Module: "@effect/stm/TSet"
* ```
*/
TSet,
/**
* @since 2.0.0
*
* ```md
* - Docs: https://effect-ts.github.io/data/modules/Tuple.ts.html

@@ -1050,0 +1320,0 @@ * - Module: "effect/Tuple"

57

index.js

@@ -6,3 +6,4 @@ "use strict";

});
exports.Tuple = exports.Tracer = exports.SynchronizedRef = exports.Symbol = exports.Supervisor = exports.Struct = exports.String = exports.SortedSet = exports.SortedMap = exports.ScopedRef = exports.ScopedCache = exports.Scope = exports.Scheduler = exports.ScheduleIntervals = exports.ScheduleInterval = exports.ScheduleDecision = exports.Schedule = exports.Runtime = exports.Resource = exports.RequestResolver = exports.RequestBlock = exports.Request = exports.Reloadable = exports.Ref = exports.RedBlackTree = exports.ReadonlyRecord = exports.ReadonlyArray = exports.Random = exports.Queue = exports.Predicate = exports.Pool = exports.Pipeable = exports.Ordering = exports.Order = exports.Option = exports.Number = exports.MutableRef = exports.MutableQueue = exports.MutableList = exports.MutableHashSet = exports.MutableHashMap = exports.MetricState = exports.MetricRegistry = exports.MetricPolling = exports.MetricPair = exports.MetricLabel = exports.MetricKeyType = exports.MetricKey = exports.MetricHook = exports.MetricBoundaries = exports.Metric = exports.LoggerSpan = exports.LoggerLevel = exports.Logger = exports.List = exports.Layer = exports.KeyedPool = exports.Hub = exports.HashSet = exports.HashMap = exports.Hash = exports.HKT = exports.Function = exports.FiberStatus = exports.FiberRuntimeFlagsPatch = exports.FiberRuntimeFlags = exports.FiberRefs = exports.FiberRef = exports.FiberId = exports.Fiber = exports.Exit = exports.ExecutionStrategy = exports.Equivalence = exports.Equal = exports.Either = exports.Effect = exports.Duration = exports.DifferOrPatch = exports.DifferHashSetPatch = exports.DifferHashMapPatch = exports.DifferContextPatch = exports.DifferChunkPatch = exports.Differ = exports.DeterministicRandom = exports.Deferred = exports.DefaultServices = exports.Data = exports.Context = exports.ConfigSecret = exports.ConfigProvider = exports.ConfigError = exports.Config = exports.Concurrency = exports.Clock = exports.Chunk = exports.Cause = exports.Cache = exports.Brand = exports.Boolean = exports.Bigint = void 0;
exports.Scope = exports.Scheduler = exports.ScheduleIntervals = exports.ScheduleInterval = exports.ScheduleDecision = exports.Schedule = exports.STM = exports.Runtime = exports.Resource = exports.RequestResolver = exports.RequestBlock = exports.Request = exports.Reloadable = exports.Ref = exports.RedBlackTree = exports.ReadonlyRecord = exports.ReadonlyArray = exports.Random = exports.Queue = exports.Predicate = exports.Pool = exports.Pipeable = exports.Ordering = exports.Order = exports.Option = exports.Number = exports.MutableRef = exports.MutableQueue = exports.MutableList = exports.MutableHashSet = exports.MutableHashMap = exports.MetricState = exports.MetricRegistry = exports.MetricPolling = exports.MetricPair = exports.MetricLabel = exports.MetricKeyType = exports.MetricKey = exports.MetricHook = exports.MetricBoundaries = exports.Metric = exports.Match = exports.LoggerSpan = exports.LoggerLevel = exports.Logger = exports.List = exports.Layer = exports.KeyedPool = exports.Hub = exports.HashSet = exports.HashMap = exports.Hash = exports.HKT = exports.GroupBy = exports.Function = exports.FiberStatus = exports.FiberRuntimeFlagsPatch = exports.FiberRuntimeFlags = exports.FiberRefs = exports.FiberRef = exports.FiberId = exports.Fiber = exports.Exit = exports.ExecutionStrategy = exports.Equivalence = exports.Equal = exports.Either = exports.Effect = exports.Duration = exports.DifferOrPatch = exports.DifferHashSetPatch = exports.DifferHashMapPatch = exports.DifferContextPatch = exports.DifferChunkPatch = exports.Differ = exports.DeterministicRandom = exports.Deferred = exports.DefaultServices = exports.Data = exports.Context = exports.ConfigSecret = exports.ConfigProvider = exports.ConfigError = exports.Config = exports.Concurrency = exports.Clock = exports.Chunk = exports.ChannelUpstreamPullStrategy = exports.ChannelUpstreamPullRequest = exports.ChannelSingleProducerAsyncInput = exports.ChannelMergeStrategy = exports.ChannelMergeState = exports.ChannelMergeDecision = exports.ChannelChildExecutorDecision = exports.Channel = exports.Cause = exports.Cache = exports.Brand = exports.Boolean = exports.Bigint = void 0;
exports.Tuple = exports.Tracer = exports.Take = exports.TSet = exports.TSemaphore = exports.TRef = exports.TReentrantLock = exports.TRandom = exports.TQueue = exports.TPriorityQueue = exports.TMap = exports.TDeferred = exports.TArray = exports.SynchronizedRef = exports.Symbol = exports.Supervisor = exports.SubscriptionRef = exports.Struct = exports.String = exports.StreamHaltStrategy = exports.StreamEmit = exports.Stream = exports.SortedSet = exports.SortedMap = exports.Sink = exports.ScopedRef = exports.ScopedCache = void 0;
Object.defineProperty(exports, "absurd", {

@@ -48,2 +49,18 @@ enumerable: true,

exports.Cause = Cause;
var Channel = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("effect/Channel"));
exports.Channel = Channel;
var ChannelChildExecutorDecision = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("effect/ChannelChildExecutorDecision"));
exports.ChannelChildExecutorDecision = ChannelChildExecutorDecision;
var ChannelMergeDecision = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("effect/ChannelMergeDecision"));
exports.ChannelMergeDecision = ChannelMergeDecision;
var ChannelMergeState = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("effect/ChannelMergeState"));
exports.ChannelMergeState = ChannelMergeState;
var ChannelMergeStrategy = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("effect/ChannelMergeStrategy"));
exports.ChannelMergeStrategy = ChannelMergeStrategy;
var ChannelSingleProducerAsyncInput = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("effect/ChannelSingleProducerAsyncInput"));
exports.ChannelSingleProducerAsyncInput = ChannelSingleProducerAsyncInput;
var ChannelUpstreamPullRequest = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("effect/ChannelUpstreamPullRequest"));
exports.ChannelUpstreamPullRequest = ChannelUpstreamPullRequest;
var ChannelUpstreamPullStrategy = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("effect/ChannelUpstreamPullStrategy"));
exports.ChannelUpstreamPullStrategy = ChannelUpstreamPullStrategy;
var Chunk = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("effect/Chunk"));

@@ -115,2 +132,4 @@ exports.Chunk = Chunk;

exports.Function = Function;
var GroupBy = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("effect/GroupBy"));
exports.GroupBy = GroupBy;
var Hash = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("effect/Hash"));

@@ -138,2 +157,4 @@ exports.Hash = Hash;

exports.LoggerSpan = LoggerSpan;
var Match = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("effect/Match"));
exports.Match = Match;
var Metric = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("effect/Metric"));

@@ -223,2 +244,4 @@ exports.Metric = Metric;

exports.ScopedRef = ScopedRef;
var Sink = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("effect/Sink"));
exports.Sink = Sink;
var SortedMap = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("effect/SortedMap"));

@@ -228,2 +251,10 @@ exports.SortedMap = SortedMap;

exports.SortedSet = SortedSet;
var STM = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("effect/STM"));
exports.STM = STM;
var Stream = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("effect/Stream"));
exports.Stream = Stream;
var StreamEmit = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("effect/StreamEmit"));
exports.StreamEmit = StreamEmit;
var StreamHaltStrategy = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("effect/StreamHaltStrategy"));
exports.StreamHaltStrategy = StreamHaltStrategy;
var String = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("effect/String"));

@@ -233,2 +264,4 @@ exports.String = String;

exports.Struct = Struct;
var SubscriptionRef = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("effect/SubscriptionRef"));
exports.SubscriptionRef = SubscriptionRef;
var Supervisor = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("effect/Supervisor"));

@@ -240,4 +273,26 @@ exports.Supervisor = Supervisor;

exports.SynchronizedRef = SynchronizedRef;
var Take = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("effect/Take"));
exports.Take = Take;
var TArray = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("effect/TArray"));
exports.TArray = TArray;
var TDeferred = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("effect/TDeferred"));
exports.TDeferred = TDeferred;
var TMap = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("effect/TMap"));
exports.TMap = TMap;
var TPriorityQueue = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("effect/TPriorityQueue"));
exports.TPriorityQueue = TPriorityQueue;
var TQueue = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("effect/TQueue"));
exports.TQueue = TQueue;
var Tracer = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("effect/Tracer"));
exports.Tracer = Tracer;
var TRandom = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("effect/TRandom"));
exports.TRandom = TRandom;
var TReentrantLock = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("effect/TReentrantLock"));
exports.TReentrantLock = TReentrantLock;
var TRef = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("effect/TRef"));
exports.TRef = TRef;
var TSemaphore = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("effect/TSemaphore"));
exports.TSemaphore = TSemaphore;
var TSet = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("effect/TSet"));
exports.TSet = TSet;
var Tuple = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("effect/Tuple"));

@@ -244,0 +299,0 @@ exports.Tuple = Tuple;

9

package.json
{
"name": "effect",
"version": "2.0.0-next.19",
"version": "2.0.0-next.20",
"license": "MIT",

@@ -10,4 +10,7 @@ "repository": {

"dependencies": {
"@effect/data": "^0.16.0",
"@effect/io": "^0.35.0"
"@effect/data": ">=0.16.0 <0.17.0",
"@effect/io": ">=0.35.0 <0.36.0",
"@effect/match": ">=0.29.0 <0.30.0",
"@effect/stm": ">=0.19.0 <0.20.0",
"@effect/stream": ">=0.30.0 <0.31.0"
},

@@ -14,0 +17,0 @@ "main": "./index.js",

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

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