ServerFactory

Constructors

constructor(lifetime: Lifetime, wireParametersFactory: () -> SocketWire.WireParameters, port: Int?, allowRemoteConnections: Boolean = false)

constructor(lifetime: Lifetime, scheduler: IScheduler, port: Int?, allowRemoteConnections: Boolean = false)

open override val change: ISource<IViewableSet.Event<SocketWire.Server>>

open override val size: Int

open override fun advise(lifetime: Lifetime, handler: (IViewableSet.Event<SocketWire.Server>) -> Unit)

open override fun advise(lifetime: Lifetime, handler: (AddRemove, SocketWire.Server) -> Unit)

fun <T> ISource<T>.~~adviseSuspend~~(lifetime: Lifetime, scheduler: IScheduler, handler: suspend (T) -> Unit)

fun <T> ISource<T>.~~adviseSuspend~~(lifetime: Lifetime, context: CoroutineContext, handler: suspend (T) -> Unit)

open operator override fun contains(element: SocketWire.Server): Boolean

open override fun isEmpty(): Boolean

suspend fun ISource<Boolean>.~~nextFalseValue~~(lifetime: Lifetime = Lifetime.Eternal): Boolean

fun ISource<Boolean>.~~nextFalseValueAsync~~(lifetime: Lifetime): Deferred<Boolean>

suspend fun <T : Any> ISource<T?>.~~nextNotNullValue~~(lifetime: Lifetime = Lifetime.Eternal): T

fun <T : Any> ISource<T?>.~~nextNotNullValueAsync~~(lifetime: Lifetime): Deferred<T>

suspend fun ISource<Boolean>.~~nextTrueValue~~(lifetime: Lifetime = Lifetime.Eternal): Boolean

fun ISource<Boolean>.~~nextTrueValueAsync~~(lifetime: Lifetime): Deferred<Boolean>

suspend fun <T> ISource<T>.~~nextValue~~(lifetime: Lifetime = Lifetime.Eternal, condition: (T) -> Boolean = { true }): T

fun <T> ISource<T>.~~nextValueAsync~~(lifetime: Lifetime, condition: (T) -> Boolean = { true }): Deferred<T>

open override fun view(lifetime: Lifetime, handler: (Lifetime, SocketWire.Server) -> Unit)