Skip to main content
Module

x/effection/lib/first.ts

Structured concurrency and effects for JavaScript
Go to Latest
File
import type { Operation, Stream } from "./types.ts";
export function first<T>(stream: Stream<T, never>): Operation<T>;export function* first<T>( stream: Stream<T, unknown>,): Operation<T | undefined> { let subscription = yield* stream.subscribe(); let result = yield* subscription.next();
if (!result.done) { return result.value; }}