NapiStream<T, S extends Object> class final

One lazy subscription and the original call's roots, shared by both targets.

snapshot produces an independently owned, non-null host envelope. It must finish all payload conversion at admission; delivery only builds the outer iterator result. releaseSnapshot drops that envelope, never a business resource. Generated transports call finishCreation after facade adoption and release every StreamDelivery after host settlement, including errors.

Constructors

NapiStream(Stream<T> source, {required S snapshot(T), void releaseSnapshot(S)?, required List<Object?> roots, ResourceOperation? operation, List<AbortSignal> signals = const [], int capacity = 64})

Properties

capacity → int

final

hashCode → int

The hash code for this object.

no setter, inherited

retainedInputs → List<Object?>

The same list is exposed to traced host roots and cleared at final release.

final

runtimeType → Type

A representation of the runtime type of the object.

no setter, inherited

Methods

deliveryFailed(Object error, StackTrace stack) → void

Aborts a failed outer-result/Promise delivery, already rejected by its host.

finishCreation(bool published) → void

Ends the synchronous factory/adoption phase, including its failure path.

next() → Future<StreamDelivery<S>>

noSuchMethod(Invocation invocation) → dynamic

Invoked when a nonexistent method or property is accessed.

inherited

return_() → Future<StreamDelivery<S>>

toString() → String

A string representation of this object.

inherited

Operators

operator ==(Object other) → bool

The equality operator.

inherited