@@ -48,7 +48,7 @@ const lens = Lens.fromSubscriptionRef(ref)
|
||||
// ^ Lens.Lens<number[], never, never, never, never>
|
||||
|
||||
const value = yield* Lens.get(lens)
|
||||
yield* Effect.forkScoped(Stream.runForEach(lens.changes, Console.log))
|
||||
yield* Effect.forkScoped(Stream.runForEach(Lens.changes(lens), Console.log))
|
||||
yield* Lens.updateEffect(lens, values =>
|
||||
Effect.fromOption(Array.replace(values, 1, 1664))
|
||||
)
|
||||
@@ -248,9 +248,9 @@ const ref = yield* SubscriptionRef.make<{
|
||||
const logUserCount = (users: View.View<readonly User[]>) =>
|
||||
Effect.gen(function*() {
|
||||
const userCount = View.map(users, users => users.length)
|
||||
yield* Console.log(`There are ${yield* userCount.get} users`)
|
||||
yield* Console.log(`There are ${yield* View.get(userCount)} users`)
|
||||
yield* Stream.runForEach(
|
||||
userCount.changes,
|
||||
View.changes(userCount),
|
||||
count => Console.log(`There are now ${count} users`),
|
||||
)
|
||||
})
|
||||
|
||||
Reference in New Issue
Block a user