Using LazyRef to Subscribe and Update with Stream Values

Is LazyRef capable of subscribing to a stream and keep the value updated?

Hello, I'm trying to use LazyRef to subscribe to a stream and keep the value updated with the stream values. If anyone is interested, in the thread

I will publish
my analysis of the code and my attempts to make it work, however the TL;DR is that the following code doesn't work as I expect:

      const theStream = Stream.fromSchedule(Schedule.spaced(100));
      const ref = yield* LazyRef.fromStream(theStream);
      yield* Effect.fork(
        Effect.gen(function* () {
          while (true) {
            const value = yield* ref.get;
            yield* Effect.log(`LazyRef value: ${value}`); // Always logs 0
            yield* Effect.sleep(50);
          }
        })
      );
      console.log(yield* theStream.pipe(Stream.take(5), Stream.runCollect)); // Logs [0, 1, 2, 3, 4]

      const theStream = Stream.fromSchedule(Schedule.spaced(100));
      const ref = yield* LazyRef.fromStream(theStream);
      yield* Effect.fork(
        Effect.gen(function* () {
          while (true) {
            const value = yield* ref.get;
            yield* Effect.log(`LazyRef value: ${value}`); // Always logs 0
            yield* Effect.sleep(50);
          }
        })
      );
      console.log(yield* theStream.pipe(Stream.take(5), Stream.runCollect)); // Logs [0, 1, 2, 3, 4]

I expect the to see the different values logged, but it always logs 0.

Effect Community•11mo ago

danielo515

Using LazyRef to Subscribe and Update with Stream Values

Is LazyRef capable of subscribing to a stream and keep the value updated?

Hello, I'm trying to use LazyRef to subscribe to a stream and keep the value updated with the stream values. If anyone is interested, in the thread

I will publish
my analysis of the code and my attempts to make it work, however the TL;DR is that the following code doesn't work as I expect:

      const theStream = Stream.fromSchedule(Schedule.spaced(100));
      const ref = yield* LazyRef.fromStream(theStream);
      yield* Effect.fork(
        Effect.gen(function* () {
          while (true) {
            const value = yield* ref.get;
            yield* Effect.log(`LazyRef value: ${value}`); // Always logs 0
            yield* Effect.sleep(50);
          }
        })
      );
      console.log(yield* theStream.pipe(Stream.take(5), Stream.runCollect)); // Logs [0, 1, 2, 3, 4]

      const theStream = Stream.fromSchedule(Schedule.spaced(100));
      const ref = yield* LazyRef.fromStream(theStream);
      yield* Effect.fork(
        Effect.gen(function* () {
          while (true) {
            const value = yield* ref.get;
            yield* Effect.log(`LazyRef value: ${value}`); // Always logs 0
            yield* Effect.sleep(50);
          }
        })
      );
      console.log(yield* theStream.pipe(Stream.take(5), Stream.runCollect)); // Logs [0, 1, 2, 3, 4]

I expect the to see the different values logged, but it always logs 0.

Using LazyRef to Subscribe and Update with Stream Values

Is LazyRef capable of subscribing to a stream and keep the value updated?

Similar Threads

Using LazyRef to Subscribe and Update with Stream Values

Is LazyRef capable of subscribing to a stream and keep the value updated?

Similar Threads

Similar Threads

Similar Threads