ValveProperty #CodePiece

CodePiece.swift

/// 弁(Valve)のように値がこなくなったら自動的に元の値に戻るProperty。
/// 元に戻る時間も指定できる。
@propertyWrapper
struct ValveProperty<Value> {
    private let relay: BehaviorRelay<Value>
    private let property: Property<Value>

    init(
        automaticallyTogglesToInitialValue initialValue: Value,
        afterInterval interval: RxTimeInterval = .milliseconds(1000),
        scheduler: SchedulerType = ConcurrentMainScheduler.instance
    ) {
        relay = .init(value: initialValue)
        property = Property(
            unsafeObservable: relay.asObservable()
                .flatMapLatest {
                    Observable.just($0)
                        .concat(
                            Observable.just(initialValue)
                                .delay(interval, scheduler: scheduler)
                        )
                }
        )
    }

    var wrappedValue: Property<Value> {
        property
    }

    var projectedValue: BehaviorRelay<Value> {
        relay
    }
}