YapDatabaseExtensions/Sources/Persistable_Remove.swift at development · danthorpe/YapDatabaseExtensions · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
//
//  Created by Daniel Thorpe on 22/04/2015.
//
//

import Foundation

extension Persistable {

    /**
    Removes the receiver using the write transaction.

    - parameter transaction: a `WriteTransactionType` transaction
    */
    public func remove<WriteTransaction: WriteTransactionType>(transaction: WriteTransaction) {
        transaction.remove(self)
    }

    /**
    Removes the receiver synchronously using a new transaction with the connection

    - parameter connection: a `ConnectionType` connection
    */
    public func remove<Connection: ConnectionType>(connection: Connection) {
        connection.remove(self)
    }

    /**
    Removes the receiver synchronously using a new transaction with the connection

    - parameter connection: a `ConnectionType` connection
    */
    public func asyncRemove<Connection: ConnectionType>(connection: Connection, queue: dispatch_queue_t = dispatch_get_main_queue(), completion: dispatch_block_t? = .None) {
        connection.asyncRemove(self, queue: queue, completion: completion)
    }

    /**
    Returns an `NSOperation` which will remove the receiver synchronously using a
    new transaction with the connection when it is executed.

    - parameter connection: a `ConnectionType` connection
    */
    public func removeOperation<Connection: ConnectionType>(connection: Connection) -> NSOperation {
        return NSBlockOperation { connection.remove(self) }
    }
}

extension SequenceType where
Generator.Element: Persistable {

    /**
    Removes the receiver using the write transaction.

    - parameter transaction: a `WriteTransactionType` transaction
    */
    public func remove<WriteTransaction: WriteTransactionType>(transaction: WriteTransaction) {
        transaction.remove(self)
    }

    /**
    Removes the receiver synchronously using a new transaction with the connection

    - parameter connection: a `ConnectionType` connection
    */
    public func remove<Connection: ConnectionType>(connection: Connection) {
        connection.remove(self)
    }

    /**
    Removes the receiver synchronously using a new transaction with the connection

    - parameter connection: a `ConnectionType` connection
    */
    public func asyncRemove<Connection: ConnectionType>(connection: Connection, queue: dispatch_queue_t = dispatch_get_main_queue(), completion: dispatch_block_t? = .None) {
        connection.asyncRemove(self, queue: queue, completion: completion)
    }

    /**
    Returns an `NSOperation` which will remove the receiver synchronously using a
    new transaction with the connection when it is executed.

    - parameter connection: a `ConnectionType` connection
    */
    public func removeOperation<Connection: ConnectionType>(connection: Connection) -> NSOperation {
        return NSBlockOperation { connection.remove(self) }
    }
}