ObjectChangesetWithToken
public class ObjectChangesetWithToken<O, T> : Publisher where O : Object
Um editor que emite ObjectChange
receive(on:)
e subscribe(on:)
pode ser chamado diretamente nesse editor, e chamar .threadSafeReference()
só é necessário se houver uma transformação intermediária. Se subscribe(on:)
for usado, ele deverá ser sempre a primeira operação no pipeline.
Crie este editor utilizando a função objectChangeset()
.
-
Este editor emite uma ObjectChange
indicando qual objeto e quais propriedades desse objeto foram alteradas cada vez que um Realm é atualizado após uma transação de escrita que modifica o objeto observado. Declaração
Swift
public typealias Output = ObjectChange<O>
-
Este editor relata um erro por meio do caso
.error
de ObjectChange.Declaração
Swift
public typealias Failure = Never
-
Especifica o agendador no qual executar operações de assinatura, cancelamento e solicitação.
Para editores do Realm, isso determina para qual fila as notificações de alteração subjacentes são enviadas. Se
receive(on:)
não for usado posteriormente, ele também determinará em quais elementos da fila recebidos do editor serão avaliados. Atualmente, apenas filas de despacho em série são suportadas e o parâmetrooptions:
não é suportado.Declaração
Swift
public func subscribe<S>(on scheduler: S) -> ObjectChangesetWithToken<O, T> where S : Scheduler
Parâmetros
scheduler
A fila de despacho serial na qual realizar a assinatura.
Valor de retorno
Um editor que se inscreve no agendador fornecido.
-
Especifica o agendador no qual realizar operações downstream.
Isso difere de
subscribe(on:)
na forma como ele é integrado ao ciclo de atualização automática. Ao usarsubscribe(on:)
, a assinatura é realizada no agendador de destino e o editor emitirá a coleção durante a atualização. Ao usarreceive(on:)
, a collection é convertida emThreadSafeReference
e entregue ao agendador de destino sem integração ao ciclo de atualização automática, o que significa que ela pode chegar algum tempo após a ocorrência da atualização.Em caso de dúvidas, você provavelmente quer
subscribe(on:)
Declaração
Swift
public func receive<S>(on scheduler: S) -> DeferredHandoverObjectChangeset<ObjectChangesetWithToken, T, S> where O == T, S : Scheduler
Parâmetros
scheduler
A fila de despacho em série para receber valores.
Valor de retorno
Um editor que fornece valores ao agendador fornecido.