subscribe

abstract suspend fun subscribe(ttl: Duration? = null, priority: StreamPriority? = null): SyncStreamSubscription(source)