you want to observe the data on a particular threa...
# rx
j
you want to observe the data on a particular thread before the subsequent operators run (synchronously)