Skip to content

Commit

Permalink
...
Browse files Browse the repository at this point in the history
  • Loading branch information
jeudesprits committed Oct 19, 2020
1 parent 1e3bac6 commit 7423b2a
Show file tree
Hide file tree
Showing 36 changed files with 77 additions and 77 deletions.
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
//
// ConditionEvaluator.swift
// PSTask
// YUKTask
//
// Created by Ruslan Lutfullin on 1/18/20.
//
Expand Down
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
//
// ConditionMutuallyExclusivityController.swift
// PSTask
// YUKTask
//
// Created by Ruslan Lutfullin on 2/11/20.
//
Expand All @@ -10,7 +10,7 @@ import Foundation
internal final class _ConditionMutuallyExclusivityController {
// MARK:
private let manageQueue =
DispatchQueue(label: "com.pstask.condition-mutually-exclusivity-controller.manage", qos: .userInitiated)
DispatchQueue(label: "com.YUKTask.condition-mutually-exclusivity-controller.manage", qos: .userInitiated)

// MARK:
private var operations = [String: [Operation]]()
Expand Down
2 changes: 1 addition & 1 deletion Sources/YUKTask/Conditions/Condition.swift
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
//
// Condition.swift
// PSTask
// YUKTask
//
// Created by Ruslan Lutfullin on 1/2/20.
//
Expand Down
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
//
// EmptyCondition.swift
// PSTask
// YUKTask
//
// Created by Ruslan Lutfullin on 1/18/20.
//
Expand Down
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
//
// MutuallyExclusiveCondition.swift
// PSTask
// YUKTask
//
// Created by Ruslan Lutfullin on 1/17/20.
//
Expand Down
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
//
// NegatedCondition.swift
// PSTask
// YUKTask
//
// Created by Ruslan Lutfullin on 1/17/20.
//
Expand Down
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
//
// NoCancelledDependenciesCondition.swift
// PSTask
// YUKTask
//
// Created by Ruslan Lutfullin on 1/17/20.
//
Expand Down
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
//
// SilentCondition.swift
// PSTask
// YUKTask
//
// Created by Ruslan Lutfullin on 1/17/20.
//
Expand Down
2 changes: 1 addition & 1 deletion Sources/YUKTask/Observers/Observer.swift
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
//
// Observer.swift
// PSTask
// YUKTask
//
// Created by Ruslan Lutfullin on 1/2/20.
//
Expand Down
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
//
// EmptyObserver.swift
// PSTask
// YUKTask
//
// Created by Ruslan Lutfullin on 1/24/20.
//
Expand Down
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
//
// TimeoutObserver.swift
// PSTask
// YUKTask
//
// Created by Ruslan Lutfullin on 1/19/20.
//
Expand Down
2 changes: 1 addition & 1 deletion Sources/YUKTask/Queue/TaskQueue.swift
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
//
// TaskQueue.swift
// PSTask
// YUKTask
//
// Created by Ruslan Lutfullin on 1/3/20.
//
Expand Down
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
//
// BlockConsumerTask.swift
// PSTask
// YUKTask
//
// Created by Ruslan Lutfullin on 1/12/20.
//
Expand Down
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
//
// BlockProducerTask.swift
// PSTask
// YUKTask
//
// Created by Ruslan Lutfullin on 1/12/20.
//
Expand Down
2 changes: 1 addition & 1 deletion Sources/YUKTask/Task/Additional Tasks/EmptyTask.swift
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
//
// EmptyTask.swift
// PSTask
// YUKTask
//
// Created by Ruslan Lutfullin on 1/30/20.
//
Expand Down
2 changes: 1 addition & 1 deletion Sources/YUKTask/Task/Additional Tasks/GatedTask.swift
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
//
// GatedTask.swift
// PSTask
// YUKTask
//
// Created by Ruslan Lutfullin on 2/2/20.
//
Expand Down
42 changes: 21 additions & 21 deletions Sources/YUKTask/Task/GroupConsumerTask.swift
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
//
// GroupConsumerTask.swift
// PSTask
// YUKTask
//
// Created by Ruslan Lutfullin on 1/5/20.
//
Expand Down Expand Up @@ -71,7 +71,7 @@ open class GroupConsumerProducerTask<Input, Output, Failure: Error>:
tasks: (T1)
) {
self.innerQueue = .init(
name: "com.pstask.\(String(describing: Self.self))-inner",
name: "\(Bundle.main.bundleIdentifier!).\(String(describing: Self.self)).inner",
qos: qos,
underlyingQueue: underlyingQueue,
startSuspended: true
Expand All @@ -91,7 +91,7 @@ open class GroupConsumerProducerTask<Input, Output, Failure: Error>:
tasks: (T1, T2)
) {
self.innerQueue = .init(
name: "com.pstask.\(String(describing: Self.self))-inner",
name: "\(Bundle.main.bundleIdentifier!).\(String(describing: Self.self)).inner",
qos: qos,
underlyingQueue: underlyingQueue,
startSuspended: true
Expand All @@ -112,7 +112,7 @@ open class GroupConsumerProducerTask<Input, Output, Failure: Error>:
tasks: (T1, T2, T3)
) {
self.innerQueue = .init(
name: "com.pstask.\(String(describing: Self.self))-inner",
name: "\(Bundle.main.bundleIdentifier!).\(String(describing: Self.self)).inner",
qos: qos,
underlyingQueue: underlyingQueue,
startSuspended: true
Expand All @@ -134,7 +134,7 @@ open class GroupConsumerProducerTask<Input, Output, Failure: Error>:
tasks: (T1, T2, T3, T4)
) {
self.innerQueue = .init(
name: "com.pstask.\(String(describing: Self.self))-inner",
name: "\(Bundle.main.bundleIdentifier!).\(String(describing: Self.self)).inner",
qos: qos,
underlyingQueue: underlyingQueue,
startSuspended: true
Expand All @@ -157,7 +157,7 @@ open class GroupConsumerProducerTask<Input, Output, Failure: Error>:
tasks: (T1, T2, T3, T4, T5)
) {
self.innerQueue = .init(
name: "com.pstask.\(String(describing: Self.self))-inner",
name: "\(Bundle.main.bundleIdentifier!).\(String(describing: Self.self)).inner",
qos: qos,
underlyingQueue: underlyingQueue,
startSuspended: true
Expand All @@ -181,7 +181,7 @@ open class GroupConsumerProducerTask<Input, Output, Failure: Error>:
tasks: (T1, T2, T3, T4, T5, T6)
) {
self.innerQueue = .init(
name: "com.pstask.\(String(describing: Self.self))-inner",
name: "\(Bundle.main.bundleIdentifier!).\(String(describing: Self.self)).inner",
qos: qos,
underlyingQueue: underlyingQueue,
startSuspended: true
Expand All @@ -206,7 +206,7 @@ open class GroupConsumerProducerTask<Input, Output, Failure: Error>:
tasks: (T1, T2, T3, T4, T5, T6, T7)
) {
self.innerQueue = .init(
name: "com.pstask.\(String(describing: Self.self))-inner",
name: "\(Bundle.main.bundleIdentifier!).\(String(describing: Self.self)).inner",
qos: qos,
underlyingQueue: underlyingQueue,
startSuspended: true
Expand All @@ -232,7 +232,7 @@ open class GroupConsumerProducerTask<Input, Output, Failure: Error>:
tasks: (T1, T2, T3, T4, T5, T6, T7, T8)
) {
self.innerQueue = .init(
name: "com.pstask.\(String(describing: Self.self))-inner",
name: "\(Bundle.main.bundleIdentifier!).\(String(describing: Self.self)).inner",
qos: qos,
underlyingQueue: underlyingQueue,
startSuspended: true
Expand All @@ -259,7 +259,7 @@ open class GroupConsumerProducerTask<Input, Output, Failure: Error>:
tasks: (T1, T2, T3, T4, T5, T6, T7, T8, T9)
) {
self.innerQueue = .init(
name: "com.pstask.\(String(describing: Self.self))-inner",
name: "\(Bundle.main.bundleIdentifier!).\(String(describing: Self.self)).inner",
qos: qos,
underlyingQueue: underlyingQueue,
startSuspended: true
Expand Down Expand Up @@ -287,7 +287,7 @@ open class GroupConsumerProducerTask<Input, Output, Failure: Error>:
tasks: (T1, T2, T3, T4, T5, T6, T7, T8, T8, T9, T10)
) {
self.innerQueue = .init(
name: "com.pstask.\(String(describing: Self.self))-inner",
name: "\(Bundle.main.bundleIdentifier!).\(String(describing: Self.self)).inner",
qos: qos,
underlyingQueue: underlyingQueue,
startSuspended: true
Expand Down Expand Up @@ -318,7 +318,7 @@ open class GroupConsumerProducerTask<Input, Output, Failure: Error>:
produced: ProducerTask<Output, Failure>
) {
self.innerQueue = .init(
name: "com.pstask.\(String(describing: Self.self))-inner",
name: "\(Bundle.main.bundleIdentifier!).\(String(describing: Self.self)).inner",
qos: qos,
underlyingQueue: underlyingQueue,
startSuspended: true
Expand All @@ -340,7 +340,7 @@ open class GroupConsumerProducerTask<Input, Output, Failure: Error>:
produced: ProducerTask<Output, Failure>
) {
self.innerQueue = .init(
name: "com.pstask.\(String(describing: Self.self))-inner",
name: "\(Bundle.main.bundleIdentifier!).\(String(describing: Self.self)).inner",
qos: qos,
underlyingQueue: underlyingQueue,
startSuspended: true
Expand All @@ -363,7 +363,7 @@ open class GroupConsumerProducerTask<Input, Output, Failure: Error>:
produced: ProducerTask<Output, Failure>
) {
self.innerQueue = .init(
name: "com.pstask.\(String(describing: Self.self))-inner",
name: "\(Bundle.main.bundleIdentifier!).\(String(describing: Self.self)).inner",
qos: qos,
underlyingQueue: underlyingQueue,
startSuspended: true
Expand All @@ -387,7 +387,7 @@ open class GroupConsumerProducerTask<Input, Output, Failure: Error>:
produced: ProducerTask<Output, Failure>
) {
self.innerQueue = .init(
name: "com.pstask.\(String(describing: Self.self))-inner",
name: "\(Bundle.main.bundleIdentifier!).\(String(describing: Self.self)).inner",
qos: qos,
underlyingQueue: underlyingQueue,
startSuspended: true
Expand All @@ -412,7 +412,7 @@ open class GroupConsumerProducerTask<Input, Output, Failure: Error>:
produced: ProducerTask<Output, Failure>
) {
self.innerQueue = .init(
name: "com.pstask.\(String(describing: Self.self))-inner",
name: "\(Bundle.main.bundleIdentifier!).\(String(describing: Self.self)).inner",
qos: qos,
underlyingQueue: underlyingQueue,
startSuspended: true
Expand All @@ -438,7 +438,7 @@ open class GroupConsumerProducerTask<Input, Output, Failure: Error>:
produced: ProducerTask<Output, Failure>
) {
self.innerQueue = .init(
name: "com.pstask.\(String(describing: Self.self))-inner",
name: "\(Bundle.main.bundleIdentifier!).\(String(describing: Self.self)).inner",
qos: qos,
underlyingQueue: underlyingQueue,
startSuspended: true
Expand All @@ -465,7 +465,7 @@ open class GroupConsumerProducerTask<Input, Output, Failure: Error>:
produced: ProducerTask<Output, Failure>
) {
self.innerQueue = .init(
name: "com.pstask.\(String(describing: Self.self))-inner",
name: "\(Bundle.main.bundleIdentifier!).\(String(describing: Self.self)).inner",
qos: qos,
underlyingQueue: underlyingQueue,
startSuspended: true
Expand Down Expand Up @@ -493,7 +493,7 @@ open class GroupConsumerProducerTask<Input, Output, Failure: Error>:
produced: ProducerTask<Output, Failure>
) {
self.innerQueue = .init(
name: "com.pstask.\(String(describing: Self.self))-inner",
name: "\(Bundle.main.bundleIdentifier!).\(String(describing: Self.self)).inner",
qos: qos,
underlyingQueue: underlyingQueue,
startSuspended: true
Expand Down Expand Up @@ -522,7 +522,7 @@ open class GroupConsumerProducerTask<Input, Output, Failure: Error>:
produced: ProducerTask<Output, Failure>
) {
self.innerQueue = .init(
name: "com.pstask.\(String(describing: Self.self))-inner",
name: "\(Bundle.main.bundleIdentifier!).\(String(describing: Self.self)).inner",
qos: qos,
underlyingQueue: underlyingQueue,
startSuspended: true
Expand Down Expand Up @@ -552,7 +552,7 @@ open class GroupConsumerProducerTask<Input, Output, Failure: Error>:
produced: ProducerTask<Output, Failure>
) {
self.innerQueue = .init(
name: "com.pstask.\(String(describing: Self.self))-inner",
name: "\(Bundle.main.bundleIdentifier!).\(String(describing: Self.self)).inner",
qos: qos,
underlyingQueue: underlyingQueue,
startSuspended: true
Expand Down
Loading

0 comments on commit 7423b2a

Please sign in to comment.