Skip to main content Link Search Menu Expand Document (external link)
effect-messaging

SubscriberRunner overview

Added in v0.3.0

Table of contents

execution

runStream

Signature

export declare const runStream: <M, ES, RS, A, E, R, EX, RX>(
  stream: Stream<M, ES, RS>,
  config: internal.StreamConfig<M, A, E, R, EX, RX>
) => Effect<void, SubscriberError, RS | R | RX>

Added in v0.3.0

models

SubscriberRunnerOptions (type alias)

Signature

export type SubscriberRunnerOptions = internal.SubscriberRunnerOptions

Added in v0.3.0