之前文章介绍的Publisher都是可以连续发送数据的,Subscriber也可以一直接收数据,除非收到了finished或者error而结束。而JUST Publisher则不同,它只向每个订阅者发送一次输出,然后结束。
一起来看一下下面的代码。
class JustViewModel: ObservableObject {func sendMessage() {let justPublisher = Just("This is a Just publisher")let cancellable = justPublisher.sink { completion inprint("---> Received completion: \(completion)")} receiveValue: { value inprint("---> Received value: \(value)")}}
}struct JustDemo: View {@StateObject private var viewModel = JustViewModel()var body: some View {VStack {Button("Send Message") {viewModel.sendMessage()}.buttonStyle(BorderedProminentButtonStyle())}}
}
上面的代码中在JustViewModel中添加了一个方法sendMessage,在该方法里面创建了一个Just Publisher,创建的时候直接传入要发送的值,然后通过sink方法添加Subscriber。
当在UI上点击按钮调用这个方法的时候,看一下输出:
 
 很明显,点击后,初始化Just发送了初始化时的值,sink方法的receiveValue闭包调用了,随后也调用了Completion闭包,结束了这次事件流。
Just Publisher给任何一个Subscriber发送数据都只发送一次,然后就调用Completion。
 比如修改一下sendMessage方法,添加两次Subscriber。
func sendMessage() {let justPublisher = Just("This is a Just publisher")// add first subscriber_ = justPublisher.sink { completion inprint("---> Received completion: \(completion)")} receiveValue: { value inprint("---> Received value: \(value)")}// add second subscriber_ = justPublisher.sink { completion inprint("---> 2 Received completion: \(completion)")} receiveValue: { value inprint("---> 2 Received value: \(value)")}
}
运行结果如下:
 
 两次订阅的sink方法的回调都被调用了,而且每个Subscriber都只接收到一次数据,然后就调用Completion闭包了。
总的来说,Just Publisher还是比较简单,也比较好理解的。
最后,希望能够帮助到有需要的朋友,如果觉得有帮助,还望点个赞,添加个关注,笔者也会不断地努力,写出更多更好用的文章。