ManagedPublisher[A: Any #share]

[Source]

A ManagedPublisher must have a SubscriberManager and give access to it.

trait tag ManagedPublisher[A: Any #share] is
  Publisher[A] tag

Implements

• Publisher[A] tag

---

Public Behaviours

subscribe

[Source]

A ManagedPublisher must respond by calling SubscriberManager._on_subscribe.

be subscribe(
  s: Subscriber[A] tag)

Parameters

• s: Subscriber[A] tag

---

on_request

[Source]

A ManagedPublisher must respond by calling SubscriberManager._on_request.

be on_request(
  s: Subscriber[A] tag,
  n: U64 val)

Parameters

• s: Subscriber[A] tag
• n: U64 val

---

on_cancel

[Source]

A ManagedPublisher must respond by calling SubscriberManager._on_cancel.

be on_cancel(
  s: Subscriber[A] tag)

Parameters

• s: Subscriber[A] tag

---