@epikodelabs/streamix

---

@epikodelabs/streamix / createSubscription

Function: createSubscription()

createSubscription(onUnsubscribe?): Subscription

Defined in: projects/libraries/streamix/src/lib/abstractions/subscription.ts:73

Creates a new Subscription instance.

This factory encapsulates subscription state and ensures:

• Safe, idempotent unsubscription
• Proper execution of cleanup logic
• Consistent error handling during teardown

Parameters

onUnsubscribe?

() => any

Optional cleanup callback executed on first unsubscribe

Returns

Subscription

A new Subscription object