MCPcopy Create free account
hub / github.com/Effect-TS/effect / stream

Method stream

packages/effect/src/unstable/reactivity/Atom.ts:180–180  ·  view source on GitHub ↗
(this: AtomContext, atom: Atom<A>, options?: {
    readonly withoutInitialValue?: boolean
    readonly bufferSize?: number
  })

Source from the content-addressed store, hash-verified

178 some<A>(this: AtomContext, atom: Atom<Option.Option<A>>): Effect.Effect<A>
179 someOnce<A>(this: AtomContext, atom: Atom<Option.Option<A>>): Effect.Effect<A>
180 stream<A>(this: AtomContext, atom: Atom<A>, options?: {
181 readonly withoutInitialValue?: boolean
182 readonly bufferSize?: number
183 }): Stream.Stream<A>

Callers 15

queryStreamFunction · 0.65
executeStreamMethod · 0.65
reactiveFunction · 0.65
multipartStreamMethod · 0.65
fileWebResponseFunction · 0.65
multipartStreamMethod · 0.65

Calls

no outgoing calls

Tested by 1

decompressFunction · 0.52