const stream = Stream.acquireRelease(aquire, ({ abort }) => Effect.succeed(abort())).pipe(
Stream.flatMap(({ stream }) => stream),
Stream.tap((response) => {
if (response.message.case === "blockScopedData") {
return Cursor.set(response.message.value.cursor);
}
return Effect.unit;
}),
Stream.retry(defaultRetryPolicy),
);
const stream = Stream.acquireRelease(aquire, ({ abort }) => Effect.succeed(abort())).pipe(
Stream.flatMap(({ stream }) => stream),
Stream.tap((response) => {
if (response.message.case === "blockScopedData") {
return Cursor.set(response.message.value.cursor);
}
return Effect.unit;
}),
Stream.retry(defaultRetryPolicy),
);