package Ġcom . m ire go . tri kot . streams . reactive Ċ Ċ import Ġorg . reactiv est ream s . Publisher Ċ import Ġorg . reactiv est ream s . Subscriber Ċ import Ġorg . reactiv est ream s . Subscription Ċ Ċ class ĠNever Publisher < T > Ġ: ĠPublisher < T > Ġ{ ĊĠĠĠ Ġoverride Ġfun Ġsubscribe ( s : ĠSubscriber < in ĠT >) Ġ{ ĊĠĠĠĠĠĠĠ Ġs . on Subscribe ( ĊĠĠĠĠĠĠĠĠĠĠĠ Ġobject Ġ: ĠSubscription Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġoverride Ġfun Ġrequest ( n : ĠLong ) Ġ{} ĊĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġoverride Ġfun Ġcancel () Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠ Ġ) ĊĠĠĠ Ġ} Ċ } Ċ