operator_dematerialize

Convert notifications back into real signals.

See Also

• MapOperator - Transform each value with a mapping function.
• MapIntoOperator - Map each value using Into.
• MapErrorOperator - Transform error values into another error value.
• MapNeverOperator - Re-type Never signals into concrete types.
• MaterializeOperator - Turn next/error/complete into notification values.
• EnumerateOperator - Attach a running index to each emission.
• PairwiseOperator - Emit the previous and current values together.

Example

cargo run -p rx_core --example operator_dematerialize_example

let _subscription = [
  ObserverNotification::<_, Never>::Next(1),
  ObserverNotification::Complete,
]
.into_observable()
.dematerialize()
.subscribe(PrintObserver::new("dematerialize_operator"));

Output:

dematerialize_operator - next: 1
dematerialize_operator - completed
dematerialize_operator - unsubscribed