dmmulroy

@effect/workflows: Comprehensive Technical Overview

A complete guide to durable workflow execution with Effect

Table of Contents

1. Introduction & Core Concepts
2. Core API Deep Dive
3. Advanced Features
4. Architecture & Data Flow

dmmulroy

Effect-Rx: Comprehensive Technical Overview

A complete guide to reactive state management with Effect

Table of Contents

1. Introduction & Core Concepts
2. Core API Deep Dive
3. Advanced Features
4. Framework Integrations

dmmulroy

/**
 * Utility functions for creating `PromiseSettledResult` instances.
 *
 * Provides methods to construct fulfilled and rejected promise results,
 * ensuring they resolve asynchronously.
 */
const PromiseSettledResult = {
  /**
   * Creates a fulfilled `PromiseSettledResult`.
   *

dmmulroy

import { Effect, Layer, Stream } from "effect";
import { handleOntraportCreateContact } from "./handle-ontraport-create-contact";
import { handleProccesMetricsUpload } from "./handle-process-metrics-upload";
import { handleSendVerificationEmail } from "./handle-send-verification-email";
import { Message } from "./message";
import { Postgres } from "./postgres";
import { RetryPolicy } from "./retry-policy";
import { flatten } from "flat";

export type JobStatus = "new" | "locked" | "completed" | "error";

dmmulroy

import { Schedule } from 'effect';
import type { Duration, DurationInput } from 'effect/Duration';

/**
 * Configuration options for exponential backoff retry strategy
 *
 * Defines the parameters for configuring a retry mechanism with exponential backoff
 *
 * @property {DurationInput} delay - Initial delay between retry attempts. Defaults to 100ms.
 * @property {number} [growthFactor=2.0] - Factor by which the delay increases exponentially.

dmmulroy

/**
 * Utility functions for creating `PromiseSettledResult` instances.
 *
 * Provides methods to construct fulfilled and rejected promise results,
 * ensuring they resolve asynchronously.
 */
const PromiseSettledResult = {
  /**
   * Creates a fulfilled `PromiseSettledResult`.
   *

dmmulroy

import { Data } from 'effect';
import type { StandardSchemaV1 } from '@standard-schema/spec';
import { type ResultAsync, errAsync, okAsync } from 'neverthrow';

export class ParseError extends Data.TaggedError('ParseError')<{
  response: Response;
  issues: ReadonlyArray<StandardSchemaV1.Issue>;
}> {}

export class UnexpectedError extends Data.TaggedError('UnexpectedError')<{

dmmulroy

# glitch_eventsub.gleam
    websocket_message.NotificationMessage(metadata, payload) -> {
      // process.send(state.websocket_message_mailbox, message)

      io.println("")
      io.println("eventsub client - notification message")
      io.debug(payload)
      io.println("")

      let assert Ok(subject) =

dmmulroy

export function mockFromArbitrary<T>(arbitrary: Arbitrary<T>): T {
  return fc.sample(arbitrary, 1)[0];
}

export function mockArrayFromArbitrary<T>(
  arbitrary: Arbitrary<T>,
  count?: number,
): T[] {
  return fc.sample(arbitrary, count);
}

dmmulroy

return {
  {
    "rcarriga/nvim-notify",
    keys = {
      {
        "<leader>un",
        function()
          require("notify").dismiss({ silent = true, pending = true })
        end,
        desc = "Dismiss All Notifications",