danielt1263

//
//  ThrottleDebounceLatest.swift
//
//  Created by Daniel Tartaglia on 14 Oct 2023.
//  Copyright © 2023 Daniel Tartaglia. MIT License.
//

import Foundation
import RxSwift

danielt1263

//
//  PollContinuously+Rx.swift
//
//  Created by Daniel Tartaglia on 20 Jun 2023.
//  Copyright © 2023 Daniel Tartaglia. MIT License.
//

import RxSwift

extension ObservableType {

danielt1263

//
//  SharedCache+Rx.swift
//
//  Created by Daniel Tartaglia on 12 Jun 2021.
//  Copyright © 2023 Daniel Tartaglia. MIT License.
//

import RxSwift

extension ObservableType {

danielt1263

// uses https://gist.github.com/danielt1263/bd449100764e3166644f7a38bca86c96

import RxSwift
import RxTest
import XCTest

final class ExampleTests: XCTestCase {
    func test_merge_second_finishes_faster() {
        let scheduler = TestScheduler(initialClock: 0)
        let args = scheduler.createObserver(Device.self)

danielt1263

//
//  AccumulatingDebounce.swift
//
//  Created by Daniel Tartaglia on 10 Mar 2023.
//  Copyright © 2023 Daniel Tartaglia. MIT License.
//

import Foundation
import RxSwift

danielt1263

func apply<A, B>(fn: (A) -> B, a: A) -> B {
    fn(a)
}

func bluebird<A, B, C>(fn1: (A) -> B, fn2: (C) -> A, c: C) -> B {
    fn1(fn2(c))
}

func blackbird<A, B, C, D>(fn1: (C) -> D, fn2: (A, B) -> C, a: A, b: B) -> D {

danielt1263

//
//  Restart.swift
//
//  Created by Daniel Tartaglia on 23 Jun 2022.
//  Copyright © 2022 Daniel Tartaglia. MIT License.
//

import RxSwift

extension ObservableType {

danielt1263

struct MenuViewModelInput {
    let fetchMenus: Observable<Void>
    let clearSelections: Observable<Void>
    let makeOrder: Observable<Void>
    let increaseMenuCount: Observable<(menu: ViewMenu, inc: Int)>
}

struct MenuViewModelOutput {
    let activated: Observable<Bool>
    let errorMessage: Observable<Error>

danielt1263

//
//  ActivityTracker.swift
//
//  Created by Daniel Tartaglia on 05 Dec 2021.
//  Copyright © 2021 Daniel Tartaglia. MIT License.
//

extension Publisher {
    func trackActivity(_ activityTracker: ActivityTracker) -> AnyPublisher<Output, Failure> {
        activityTracker.trackActivity(of: self)

danielt1263

import Cause_Logic_Effect
import RxCocoa
import RxSwift
import RxSwiftExt
import UIKit

final class ViewController: UIViewController {
    var tableView: UITableView!
    var logoutButton: UIButton!
    let disposeBag = DisposeBag()