Skip to content

Instantly share code, notes, and snippets.

@jeffersonsetiawan
Created December 1, 2021 05:08
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save jeffersonsetiawan/a7ff5696a89257d95def81def0dbbbd6 to your computer and use it in GitHub Desktop.
Save jeffersonsetiawan/a7ff5696a89257d95def81def0dbbbd6 to your computer and use it in GitHub Desktop.
AnonymousObservable.run snippet
// AnonymousObservable class
override func run<Observer: ObserverType>(_ observer: Observer, cancel: Cancelable) -> (sink: Disposable, subscription: Disposable) where Observer.Element == Element {
let sink = AnonymousObservableSink(observer: observer, cancel: cancel)
let subscription = sink.run(self)
return (sink: sink, subscription: subscription)
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment