Makes `observer` in `Sink` private again.
This commit is contained in:
parent
59f3b487d2
commit
ceb14acadb
|
|
@ -20,8 +20,6 @@ class DistinctUntilChangedSink<O: ObserverType, Key>: Sink<O>, ObserverType {
|
|||
}
|
||||
|
||||
func on(event: Event<E>) {
|
||||
let observer = super.observer
|
||||
|
||||
switch event {
|
||||
case .Next(let value):
|
||||
do {
|
||||
|
|
|
|||
|
|
@ -77,8 +77,6 @@ class FlatMapSink<SourceType, S: ObservableConvertibleType, O: ObserverType wher
|
|||
}
|
||||
|
||||
func on(event: Event<SourceType>) {
|
||||
let observer = super.observer
|
||||
|
||||
switch event {
|
||||
case .Next(let element):
|
||||
do {
|
||||
|
|
|
|||
|
|
@ -25,8 +25,6 @@ class MapSink<SourceType, O : ObserverType> : Sink<O>, ObserverType {
|
|||
}
|
||||
|
||||
func on(event: Event<SourceType>) {
|
||||
let observer = super.observer
|
||||
|
||||
switch event {
|
||||
case .Next(let element):
|
||||
do {
|
||||
|
|
|
|||
|
|
@ -9,20 +9,20 @@
|
|||
import Foundation
|
||||
|
||||
class Sink<O : ObserverType> : SingleAssignmentDisposable {
|
||||
let observer: O
|
||||
private let _observer: O
|
||||
|
||||
func forwardOn(event: Event<O.E>) {
|
||||
if disposed {
|
||||
return
|
||||
}
|
||||
observer.on(event)
|
||||
_observer.on(event)
|
||||
}
|
||||
|
||||
init(observer: O) {
|
||||
#if TRACE_RESOURCES
|
||||
OSAtomicIncrement32(&resourceCount)
|
||||
#endif
|
||||
self.observer = observer
|
||||
_observer = observer
|
||||
}
|
||||
|
||||
deinit {
|
||||
|
|
|
|||
Loading…
Reference in New Issue