结合subscribe(on:options:)操作符

我有一个关于subscribe(on:options:)操作符的问题。如果有人能帮我弄清楚，我将不胜感激。

所以我们从文档中得到了什么：

指定在其上执行订阅、取消和请求操作的调度程序。与影响下游消息的 receive(on:options:) 相比，subscribe(on:options:) 改变了上游消息的执行上下文。

另外，我从不同的文章中得到的是，除非我们明确指定Scheduler在 (using receive(on:options:))上接收我们的下游消息，否则消息将在Scheduler用于接收订阅的上发送。

这些信息与我在执行过程中实际获得的信息不一致。

我有下一个代码：

Just("Some text")
    .map { _ in
        print("Map: (Thread.isMainThread)")
    }
    .subscribe(on: DispatchQueue.global())
    .sink { _ in
        print("Sink: (Thread.isMainThread)")
    }
    .store(in: &subscriptions)

我希望下一个输出：

Map: false
Sink: false

Map: false
Sink: false

Map: false
Sink: false

但相反，我得到：

Map: true
Sink: false

当我使用Sequence发布者时也会发生同样的事情。

如果我交换map操作员和subscribe操作员的位置，我会得到我想要的：

Just("Some text")
    .subscribe(on: DispatchQueue.global())
    .map { _ in
        print("Map: (Thread.isMainThread)")
    }
    .sink { _ in
        print("Sink: (Thread.isMainThread)")
    }
    .store(in: &subscriptions)

输出：

有趣的事实是，当我使用与自定义发布商的第一个列表相同的运算符顺序时，我会收到我想要的行为：

struct TestJust<Output>: Publisher {
    typealias Failure = Never
    
    private let value: Output
    
    init(_ output: Output) {
        self.value = output
    }
    
    func receive<S>(subscriber: S) where S : Subscriber, Failure == S.Failure, Output == S.Input {
        subscriber.receive(subscription: Subscriptions.empty)
        _ = subscriber.receive(value)
        subscriber.receive(completion: .finished)
    }
}

TestJust("Some text")
    .map { _ in
        print("Map: (Thread.isMainThread)")
    }
    .subscribe(on: DispatchQueue.global())
    .sink { _ in
        print("Sink: (Thread.isMainThread)")
    }
    .store(in: &subscriptions)

输出：

所以我认为要么是我对所有这些机制的完全误解，要么是一些发布者故意选择发布值的线程（Just, Sequence-> Main, URLSession.DataTaskPublisher-> Some of Background），这对我来说没有意义，因为在这种情况下我们为什么需要这个subscribe(on:options:)为了。

你能帮我理解我错过了什么吗？先感谢您。

回答

Just("Some text")
    .handleEvents(receiveRequest: {
        _ in print("Handle1: (Thread.isMainThread)")
    })
    .map // etc.

Just("Some text")
    .receive(on: DispatchQueue.main)