Processor[A: Any #share, B: Any #share]

[Source]

A Processor represents a processing stage—which is both a Subscriber and a Publisher and obeys the contracts of both.

interface tag Processor[A: Any #share, B: Any #share] is
  Subscriber[A] tag,
  Publisher[B] tag

Implements

• Subscriber[A] tag
• Publisher[B] tag

---

Public Behaviours

on_subscribe

be on_subscribe(
  s: Subscription iso)

Parameters

• s: Subscription iso

---

on_next

be on_next(
  a: A)

Parameters

• a: A

---

on_error

be on_error(
  e: ReactiveError val)

Parameters

• e: ReactiveError val

---

on_complete

be on_complete()

---

subscribe

be subscribe(
  s: Subscriber[B] tag)

Parameters

• s: Subscriber[B] tag

---