zio/zio.internal/Hub/Subscription

Subscription

abstract class Subscription[A] extends Serializable

A Subscription[A] is a subscription to receive A values from the hub. The guarantee is that a subscriber will receive all values published to hub while it is subscribed.

class Object
trait Matchable
class Any

Value members

Abstract methods

def isEmpty(): Boolean

Checks whether there are values available to take from the hub.

Checks whether there are values available to take from the hub.

def poll(default: A): A

Takes a value from the hub if there is one or else returns the specified default value.

Takes a value from the hub if there is one or else returns the specified default value.

def pollUpTo(n: Int): Chunk[A]

Takes up to the specified number of values from the hub.

Takes up to the specified number of values from the hub.

def size(): Int

The current number of values available to take from the hub.

The current number of values available to take from the hub.

def unsubscribe(): Unit

Unsubscribes this subscriber from the hub.

Unsubscribes this subscriber from the hub.