@flux-control/effect-modbus-rs
    Preparing search index...

    Class RtuTransportService

    Scoped Effect service wrapping the modbus-rs AsyncRtuTransport for RTU (serial) Modbus communication.

    The transport connection is opened lazily on the first call to withClient(unitId) and automatically closed when the consuming Effect.Scope | Scope finalizes.

    Clients are created per unitId via AsyncRtuTransport.createClient and cached, so repeated requests for the same unit ID reuse the same client.

    • AsyncRtuTransport — Upstream modbus-rs RTU transport.
    • RtuTransportOpenOptions — Configuration for the RTU serial port.
    • makeTransportScoped — Generic lifecycle logic from shared-transport.

    Hierarchy

    • {
          clearRequestTimeout: (
              ...args: [],
          ) => Effect<undefined, ModbusNotConnectedError, never>;
          close: (...args: []) => Effect<void, ModbusError, Scope>;
          connectionState: SubscriptionRef<
              {}
              | {}
              | { attempt: number }
              | { cause: ModbusError },
          >;
          hasPendingRequests: () => boolean;
          reconnect: (...args: []) => Effect<undefined, ModbusError, never>;
          setRequestTimeout: (
              ...args: [timeoutMs: number],
          ) => Effect<undefined, ModbusNotConnectedError, never>;
          withClient: (
              ...args: [
                  unitId: number,
                  clientOptions?: { retry?: ModbusRetryPolicy },
              ],
          ) => Effect<EffectModbusClient, ModbusError, never>;
      } & {}
      • RtuTransportService
    Index
    constructor
    clearRequestTimeout close connectionState hasPendingRequests reconnect setRequestTimeout withClient
    makeMockTransport

    • Parameters

      • _: {
            clearRequestTimeout: (
                ...args: [],
            ) => Effect<undefined, ModbusNotConnectedError, never>;
            close: (...args: []) => Effect<void, ModbusError, Scope>;
            connectionState: SubscriptionRef<
                {}
                | {}
                | { attempt: number }
                | { cause: ModbusError },
            >;
            hasPendingRequests: () => boolean;
            reconnect: (...args: []) => Effect<undefined, ModbusError, never>;
            setRequestTimeout: (
                ...args: [timeoutMs: number],
            ) => Effect<undefined, ModbusNotConnectedError, never>;
            withClient: (
                ...args: [
                    unitId: number,
                    clientOptions?: { retry?: ModbusRetryPolicy },
                ],
            ) => Effect<EffectModbusClient, ModbusError, never>;
        }

      Returns RtuTransportService

    clearRequestTimeout: (
        ...args: [],
    ) => Effect<undefined, ModbusNotConnectedError, never> = ...
    close: (...args: []) => Effect<void, ModbusError, Scope> = ...
    connectionState: SubscriptionRef<
        {}
        | {}
        | { attempt: number }
        | { cause: ModbusError },
    >
    hasPendingRequests: () => boolean = ...
    reconnect: (...args: []) => Effect<undefined, ModbusError, never> = ...
    setRequestTimeout: (
        ...args: [timeoutMs: number],
    ) => Effect<undefined, ModbusNotConnectedError, never> = ...
    withClient: (
        ...args: [unitId: number, clientOptions?: { retry?: ModbusRetryPolicy }],
    ) => Effect<EffectModbusClient, ModbusError, never> = ...

    • Creates a Layer providing an in-memory mock RtuTransportService for testing or development.

      Accepts an array of SlaveDeviceDefinition describing the simulated Modbus slaves and their register/coil maps.

      Parameters

      • devices: readonly {
            coils: readonly { address: number; default: boolean }[];
            discreteInputs: readonly { address: number; default: boolean }[];
            holdingRegisters: readonly { address: number; default: number }[];
            inputRegisters: readonly { address: number; default: number }[];
            unitId: number;
        }[]

        Slave device definitions for the mock.

      Returns (
          options: RtuTransportOpenOptions & TransportResilienceOptions & MockFaultOptions,
      ) => Layer<RtuTransportService, never, never>

      A function that takes RtuTransportOpenOptions and returns a scoped Layer providing the mock service.

      makeMockTransport — The underlying mock factory.

    Settings
    Member Visibility

    On This Page
    Constructors
    Properties
    Methods